diff --git a/src/prefect/tasks.py b/src/prefect/tasks.py index 99772529571e..90f57daa51ff 100644 --- a/src/prefect/tasks.py +++ b/src/prefect/tasks.py @@ -752,9 +752,9 @@ async def create_run( dynamic_key = ( _dynamic_key_for_task_run(context=flow_run_context, task=self) if flow_run_context - else str(uuid4().hex) + else f"{self.task_key}-{str(uuid4().hex)}" ) - task_run_name += f"-{str(dynamic_key)[:3]}" + task_run_name += f"-{dynamic_key}" if deferred: state = Scheduled()