task finally

kuaukutsu · Dec 16, 2023 · ddef4c9 · ddef4c9
1 parent 4403c32
commit ddef4c9
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 4 deletions.
diff --git a/src/EntityFinally.php b/src/EntityFinally.php
@@ -8,5 +8,8 @@
 
 interface EntityFinally
 {
-    public function handle(TaskStateInterface $state): void;
+    /**
+     * @param non-empty-string $uuid Task UUID
+     */
+    public function handle(string $uuid, TaskStateInterface $state): void;
 }
diff --git a/src/handler/TaskFinallyHandler.php b/src/handler/TaskFinallyHandler.php
@@ -22,14 +22,17 @@ public function __construct(private readonly ContainerInterface $container)
     {
     }
 
-    public function handle(TaskOptions $options, TaskStateInterface $state): void
+    /**
+     * @param non-empty-string $uuid Task UUID
+     */
+    public function handle(string $uuid, TaskOptions $options, TaskStateInterface $state): void
     {
         if ($options->finally === null) {
             return;
         }
 
         try {
-            $this->factory($options->finally)->handle($state);
+            $this->factory($options->finally)->handle($uuid, $state);
         } catch (Throwable) {
         }
     }

diff --git a/src/processing/TaskHandler.php b/src/processing/TaskHandler.php
@@ -109,7 +109,12 @@ public function complete(string $taskUuid, string $stageUuid): TaskStateInterfac
             return $stateRelation;
         }
 
-        $this->finallyHandler->handle($task->getOptions(), $state);
+        $this->finallyHandler->handle(
+            $task->getUuid(),
+            $task->getOptions(),
+            $state,
+        );
+
         return $state;
     }