David Michael Carter
06/01/2023, 4:52 PMdef generate_task_run_name_foo(dataset: dict, **kwargs):
return 'Foo: ' + dataset['name']
@task(max_retries=RETRY_COUNT, retry_delay=RETRY_DELAY, log_stdout=True, task_run_name=generate_task_run_name_foo)
def foo(dataset: dict):
...
David Michael Carter
06/01/2023, 7:11 PMfoo
args are not being passed into generate_task_run_name_foo
like they would in Prefect 1:
TypeError: generate_task_run_name_foo() missing 1 required positional argument: 'dataset'