File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -12,6 +12,7 @@ class Consts
1212 const STATUS_DONE = 2 ;
1313 const STATUS_COMPLETED_NOT_DONE = 6 ;
1414 const STATUS_WAITING_FOR_RETRY = 7 ;
15+ const STATUS_SENT_TO_QUEUE_FOR_EXECUTION = 10 ;
1516
1617 const PRIORITY_LOW = 11 ;
1718 const PRIORITY_MEDIUM = 41 ;
Original file line number Diff line number Diff line change 22
33namespace G4 \Tasker \Tasker2 ;
44
5+ use G4 \Tasker \Consts ;
56use G4 \Tasker \Tasker2 \Exception \RabbitmqNotAvailableException ;
67use G4 \Tasker \Tasker2 \Queue \BatchPublisher ;
78use PhpAmqpLib \Connection \AMQPStreamConnection ;
@@ -116,8 +117,7 @@ private function updateStatus()
116117 if (count ($ this ->tasks ) === 0 ) {
117118 return $ this ;
118119 }
119- // update status sent to queue for execution
120- $ this ->taskRepository ->updateStatus (10 , ...$ this ->tasks );
120+ $ this ->taskRepository ->updateStatus (Consts::STATUS_SENT_TO_QUEUE_FOR_EXECUTION , ...$ this ->tasks );
121121 return $ this ;
122122 }
123123}
You can’t perform that action at this time.
0 commit comments