p

    Payam Vaezi

    1 year ago
    Hi all, I'm trying to execute a simple workflow on prefect server (deployed on a custom k8s) and getting this error when cloud runner executes the flow:
    │ [2021-08-17 12:20:57+0000] INFO - prefect.S3 | Flow successfully downloaded. ETag: "ae24fd937c7bfe0317bf996718070f86", LastModified: 2021-08-17T12:13:58+00:00, VersionId: JLZcoHjb99CPDG │
    │ [2021-08-17 12:20:58+0000] INFO - prefect.CloudFlowRunner | Beginning Flow run for '44cf3c22-40d8-427c-bbf2-d40d4ca113e5'                                                                 │
    │ [2021-08-17 12:20:58+0000] INFO - prefect.CloudTaskRunner | Task 'source': Starting task run...                                                                                           │
    │ [2021-08-17 12:20:58+0000] INFO - prefect.CloudTaskRunner | Task 'source': Finished task run for task with final state: 'Running'                                                         │
    │ [2021-08-17 12:20:58+0000] INFO - prefect.CloudTaskRunner | Task 'sink': Starting task run...                                                                              │
    │ [2021-08-17 12:20:58+0000] INFO - prefect.CloudTaskRunner | Task 'sink': Finished task run for task with final state: 'Pending'                                            │
    │ [2021-08-17 12:20:58+0000] INFO - prefect.CloudFlowRunner | Flow run RUNNING: terminal tasks are incomplete.
    Haven't seen this problem in local runs! Can someone advise me what may be wrong (I'm getting this intermittently)?
    Kevin Kho

    Kevin Kho

    1 year ago
    Hey @Payam Vaezi, do you mean the flow just stops because there is a task with final state running? What does that task do? Could you show me the flow code?