acoustic-carpenter-78188
02/08/2023, 2:21 PMflytekit>=1.3.0, the following error message appears when workflows are run:
Workflow[dask-plugin:development:demo.dask_demo.workflows.dynamic_workflow] failed. RuntimeExecutionError: max number of system retry attempts [11/10] exhausted. Last known status message: InvalidArgument: Invalid fields for event message, caused by [rpc error: code = InvalidArgument desc = missing project]
Example workflow:
from flytekit import workflow, task, dynamic
@task
def some_task():
print("Do something")
@dynamic
def dynamic_task():
some_task()
@workflow
def dynamic_workflow():
dynamic_task()
The workflow was serialized using pyflyte -k <package> serialize --image <image> workflows -f <output_dir.
A bit of investigation lead to possibly flyteorg/flytekit#1378 being the root cause of this.
Expected behavior
The dynamic workflow should run
Additional context to reproduce
No response
Screenshots
No response
Are you sure this issue hasn't been raised already?
☑︎ Yes
Have you read the Code of Conduct?
☑︎ Yes
flyteorg/flyte