diff --git a/flytekit/core/python_function_task.py b/flytekit/core/python_function_task.py index ba87cdce35..1edbd61809 100644 --- 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: