From 1c2918b903521a31443fdd0dd893445cc0c84e54 Mon Sep 17 00:00:00 2001 From: Daniel Nagy Date: Wed, 13 Apr 2016 17:33:09 +0200 Subject: [PATCH] Added inversed dependencies to Job entity --- Entity/Job.php | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/Entity/Job.php b/Entity/Job.php index de8e42ad..45de1296 100644 --- a/Entity/Job.php +++ b/Entity/Job.php @@ -126,7 +126,7 @@ class Job private $args; /** - * @ORM\ManyToMany(targetEntity = "Job", fetch = "EAGER") + * @ORM\ManyToMany(targetEntity = "Job", inversedBy = "dependers", fetch = "EAGER") * @ORM\JoinTable(name="jms_job_dependencies", * joinColumns = { @ORM\JoinColumn(name = "source_job_id", referencedColumnName = "id") }, * inverseJoinColumns = { @ORM\JoinColumn(name = "dest_job_id", referencedColumnName = "id")} @@ -134,6 +134,9 @@ class Job */ private $dependencies; + /** @ORM\ManyToMany(targetEntity = "Job", mappedBy="dependencies") */ + private $dependers; + /** @ORM\Column(type = "text", nullable = true) */ private $output; @@ -206,6 +209,7 @@ public function __construct($command, array $args = array(), $confirmed = true, $this->executeAfter = new \DateTime(); $this->executeAfter = $this->executeAfter->modify('-1 second'); $this->dependencies = new ArrayCollection(); + $this->dependers = new ArrayCollection(); $this->retryJobs = new ArrayCollection(); $this->relatedEntities = new ArrayCollection(); } @@ -408,6 +412,11 @@ public function addDependency(Job $job) $this->dependencies->add($job); } + public function getDependers() + { + return $this->dependers; + } + public function getRuntime() { return $this->runtime;