fix: referendum job (#82)

code4romania · Nov 24, 2024 · 384645e · 384645e
1 parent c9871df
commit 384645e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/app/Jobs/ReferendumBucuresti241124/Turnouts/FetchTurnoutsJob.php b/app/Jobs/ReferendumBucuresti241124/Turnouts/FetchTurnoutsJob.php
@@ -68,6 +68,7 @@ public function execute(): void
 
         Bus::batch([new ImportTurnoutsJob($this->scheduledJob, County::find(403))])
             ->catch($persistAndClean)
+            ->then($persistAndClean)
             ->then(fn () => UpdateElectionTurnoutsTimestamp::dispatch($electionId))
             ->name("$electionName / Prezență / $time")
             ->allowFailures()

diff --git a/app/Jobs/SchedulableJob.php b/app/Jobs/SchedulableJob.php
@@ -42,4 +42,9 @@ final public function handle(): void
 
         $this->scheduledJob->touch('last_run_at');
     }
+
+    public function uniqueId(): string
+    {
+        return "scheduled-job:{$this->scheduledJob->id}";
+    }
 }