Rename variable
This commit is contained in:
parent
6439bc9ad5
commit
de184d761e
1 changed files with 9 additions and 9 deletions
|
@ -83,17 +83,17 @@ abstract class ThirdPartyCeleryService extends ThirdPartyService {
|
|||
protected function _createTaskReference($fileId, $brokerTaskId, $taskName) {
|
||||
$trackId = $this->createTrackReference($fileId);
|
||||
// First, check if the track already has an entry in the database
|
||||
$ref = CeleryTasksQuery::create()->findOneByDbId($brokerTaskId);
|
||||
if (is_null($ref)) {
|
||||
$ref = new CeleryTasks();
|
||||
$task = CeleryTasksQuery::create()->findOneByDbId($brokerTaskId);
|
||||
if (is_null($task)) {
|
||||
$task = new CeleryTasks();
|
||||
}
|
||||
$ref->setDbId($brokerTaskId);
|
||||
$ref->setDbName($taskName);
|
||||
$task->setDbId($brokerTaskId);
|
||||
$task->setDbName($taskName);
|
||||
$utc = new DateTimeZone("UTC");
|
||||
$ref->setDbDispatchTime(new DateTime("now", $utc));
|
||||
$ref->setDbStatus(CELERY_PENDING_STATUS);
|
||||
$ref->setDbTrackReference($trackId);
|
||||
$ref->save();
|
||||
$task->setDbDispatchTime(new DateTime("now", $utc));
|
||||
$task->setDbStatus(CELERY_PENDING_STATUS);
|
||||
$task->setDbTrackReference($trackId);
|
||||
$task->save();
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue