Skip to content

Commit 5c489cc

Browse files
fixed code-style
1 parent d7f9d96 commit 5c489cc

File tree

3 files changed

+21
-12
lines changed

3 files changed

+21
-12
lines changed

src/DoctrineStorage/TaskExecutionRepository.php

Lines changed: 17 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -33,27 +33,27 @@ public function __construct(ObjectManager $objectManager, ORMTaskExecutionReposi
3333
/**
3434
* {@inheritdoc}
3535
*/
36-
public function save(TaskExecutionInterface $execution)
36+
public function store(TaskExecutionInterface $execution)
3737
{
3838
$this->objectManager->persist($execution);
39+
40+
// FIXME move this flush to somewhere else (:
3941
$this->objectManager->flush();
42+
43+
return $this;
4044
}
4145

4246
/**
4347
* {@inheritdoc}
4448
*/
45-
public function add(TaskExecutionInterface $execution)
49+
public function save(TaskExecutionInterface $execution)
4650
{
4751
$this->objectManager->persist($execution);
52+
53+
// FIXME move this flush to somewhere else (:
4854
$this->objectManager->flush();
49-
}
5055

51-
/**
52-
* {@inheritdoc}
53-
*/
54-
public function findScheduled()
55-
{
56-
return $this->taskExecutionRepository->findScheduled(new \DateTime());
56+
return $this;
5757
}
5858

5959
/**
@@ -64,13 +64,19 @@ public function findByStartTime(TaskInterface $task, \DateTime $scheduleTime)
6464
return $this->taskExecutionRepository->findByStartTime($task, $scheduleTime);
6565
}
6666

67+
/**
68+
* {@inheritdoc}
69+
*/
6770
public function findAll($limit = null)
6871
{
6972
return $this->taskExecutionRepository->findBy([], ['scheduleTime' => 'ASC'], $limit);
7073
}
7174

72-
public function get($uuid)
75+
/**
76+
* {@inheritdoc}
77+
*/
78+
public function findScheduled()
7379
{
74-
// TODO: Implement get() method.
80+
return $this->taskExecutionRepository->findScheduled(new \DateTime());
7581
}
7682
}

src/Resources/config/scheduler.xml

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99
<argument type="service" id="task.factory"/>
1010
<argument type="service" id="task.storage.task"/>
1111
<argument type="service" id="task.storage.task_execution"/>
12+
<argument type="service" id="event_dispatcher"/>
1213
</service>
1314

1415
<service id="task.handler.factory" class="Task\TaskBundle\Handler\TaskHandlerFactory">
@@ -18,6 +19,7 @@
1819
<service id="task.runner" class="Task\Runner\TaskRunner">
1920
<argument type="service" id="task.storage.task_execution"/>
2021
<argument type="service" id="task.handler.factory"/>
22+
<argument type="service" id="event_dispatcher"/>
2123
</service>
2224
</services>
2325
</container>

src/Resources/config/task_event_listener.xml

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,9 @@
55

66
<parameters>
77
<parameter key="task.events.create" type="constant">Task\Event\Events::TASK_CREATE</parameter>
8+
<parameter key="task.events.create_execution" type="constant">Task\Event\Events::TASK_EXECUTION_CREATE</parameter>
89
<parameter key="task.events.before" type="constant">Task\Event\Events::TASK_BEFORE</parameter>
9-
<parameter key="task.events.after" type="constant">Task\Event\Events::TASK_AFTER</parameter>
10+
<parameter key="task.events.finished" type="constant">Task\Event\Events::TASK_FINISHED</parameter>
1011
<parameter key="task.events.passed" type="constant">Task\Event\Events::TASK_PASSED</parameter>
1112
<parameter key="task.events.failed" type="constant">Task\Event\Events::TASK_FAILED</parameter>
1213
</parameters>

0 commit comments

Comments
 (0)