本地级长项目不会打印/记录结果

2024-10-03 19:27:57 发布

您现在位置:Python中文网/ 问答频道 /正文

我已经试着跑了一段时间了

基本上,有一个任务返回一个参数字典(make_poem),还有一个流根据参数打印一些东西(declaim_poem)。还有以下父流:

flow_run = StartFlowRun(flow_name="declaim_flow", project_name=project_name)
with Flow("param_flow") as flow:
    flow_run.set_upstream(task(make_poem), key="parameters")

这比ran更重要,结果如下:

[2021-08-01 17:04:05+0200] INFO - prefect.FlowRunner | Beginning Flow run for 'param_flow'
[2021-08-01 17:04:05+0200] INFO - prefect.FlowRunner | Beginning Flow run for 'param_flow'
[2021-08-01 17:04:05+0200] INFO - prefect.FlowRunner | Beginning Flow run for 'param_flow'
[2021-08-01 17:04:05+0200] INFO - prefect.FlowRunner | Beginning Flow run for 'param_flow'
[2021-08-01 17:04:05+0200] INFO - prefect.TaskRunner | Task 'make_poem': Starting task run...
[2021-08-01 17:04:05+0200] INFO - prefect.TaskRunner | Task 'make_poem': Finished task run for task with final state: 'Success'
[2021-08-01 17:04:05+0200] INFO - prefect.TaskRunner | Task 'Flow declaim_flow': Starting task run...
[2021-08-01 17:04:06+0200] INFO - prefect.Flow declaim_flow | Flow Run: < cloud link >
[2021-08-01 17:04:06+0200] INFO - prefect.TaskRunner | Task 'Flow declaim_flow': Finished task run for task with final state: 'Success'
[2021-08-01 17:04:06+0200] INFO - prefect.FlowRunner | Flow run SUCCESS: all reference tasks succeeded

即使这是一个成功的结果,我也无法从declaim_poem(正如所暗示的,一首诗)中获得预期的输出以在屏幕上打印出来。我使用的是在declaim_poem任务中实例化的记录器,而不是根据this page使用的流

在提供的完美云链接中,我也找不到这首诗,只有来自所有流程的所有任务的成功结果

你知道我做错了什么吗


Tags: runinfofortaskmakeparamflowtaskrunner