Josh
04/20/2022, 3:21 AMError during execution of task: ClientError([{'path': ['create_task_run_artifact'], 'message': 'Task run <task_run_id> not found', 'extensions': {'code': 'INTERNAL_SERVER_ERROR'}}])
Kevin Kho
Josh
04/20/2022, 5:09 PMKevin Kho
task.run()
inside a task
inside a Flow
? Or just a task.run not in a Flow?Josh
04/20/2022, 5:16 PMclass Task():
def run():
# do something
create_markdown()
task = Task()
with Flow("my flow") as Flow:
task()
Kevin Kho
Josh
04/20/2022, 10:07 PMKevin Kho
from prefect import Task, Flow
from prefect.backend.artifacts import create_markdown_artifact
class MyTask(Task):
def run(self, x):
create_markdown_artifact("# Heading\n\nText with [link](<https://www.prefect.io/>).")
mytask = MyTask()
with Flow("artifact_test") as flow:
mytask.map(list(range(100)))
flow.register("databricks")
Josh
04/21/2022, 6:58 PMKevin Kho
Vinny Tunnell
05/15/2022, 10:48 PMcreate_markdown_artifact
. This was working fine for us for the last few weeks, but this error was thrown multiple times yesterday. We are using LocalDaskExecutor with a Kubernetes agent.