public function scheduleWork()
    {
        if (is_null($this->scheduler)) {
            return;
        }

        $this->scheduler->reconnect();

        foreach ($this->scheduler->getJobsFor(new \DateTime()) as $job) {
            $this->pipeline->enqueue($job);
        }
    }
public function scheduleWork()
    {
        if (is_null($this->scheduler)) {
            return;
        }

        $this->scheduler->reconnect();

        foreach ($this->scheduler->getJobsFor(new \DateTime()) as $job) {
            $this->pipeline->enqueue($job);
        }
    }
public function scheduleWork ( ) { if ( is_null ( $ this -> scheduler ) ) { return ; } $ this -> scheduler -> reconnect ( ) ; foreach ( $ this -> scheduler -> getJobsFor ( new \ DateTime ( ) ) as $ job ) { $ this -> pipeline -> enqueue ( $ job ) ; } }
Check the schedule for work to enqueue and push it into the pipeline if needed
Check the schedule for work to enqueue and push it into the pipeline if needed