add name

Signed-off-by: Yee Hing Tong <[email protected]>
flyteorg · Feb 22, 2025 · a7e1bdf · a7e1bdf
1 parent 367a393
commit a7e1bdf
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/flytekit/core/python_function_task.py b/flytekit/core/python_function_task.py
@@ -730,8 +730,7 @@ def dispatch_execute(self, ctx: FlyteContext, input_literal_map: LiteralMap) ->
 
         remote = get_plugin().get_remote(config=None, project=project, domain=domain)
         key_filter = ValueIn("execution_tag.key", ["eager-exec"])
-        # todo: add value filter
-        value_filter = ValueIn("execution_tag.key", ["eager-exec"])
+        value_filter = ValueIn("execution_tag.value", [name])
         phase_filter = ValueNotIn("phase", ["ABORTED", "SUCCEEDED", "FAILED", "TIMED_OUT"])
         # This should be made more robust, currently lacking retries and exception handling
         while True: