prefect icon indicating copy to clipboard operation
prefect copied to clipboard

Flow run errors frequently with `prefect._internal.concurrency - Service 'EventsWorker' failed to process item`

Open discdiver opened this issue 1 year ago • 0 comments

Bug summary

When debugging level is set to INFO the following script fails about every third run with ERROR | GlobalEventLoopThread | prefect._internal.concurrency - Service 'EventsWorker' failed to process item Event...

Switching to DEBUG level logging, it always completes, but then I get a Warning like this:

...
12:45:55.595 | DEBUG   | prefect.client - Connecting to API at https://api.prefect.cloud/api/accounts/9b649228-0419-40e1-9e0d-44954b5c0ab6/workspaces/d137367a-5055-44ff-b91c-6f7366c9e4c4/
12:45:55.596 | WARNING | EventsWorker - Still processing items: 3 items remaining...
from prefect import flow, task
import pandas as pd


@task
def get_data():
    df = pd.DataFrame({"A": [1, 2, 3], "B": [4, 5, 6], "C": [7, 8, 9]})
    df.index = pd.date_range("2020-01-01", periods=3)
    return df


@flow()
def my_flow():
    data = get_data()
    return data


if __name__ == "__main__":
    x = my_flow()
    print(x)

Version info (prefect version output)

Version:             3.0.0rc19
API version:         0.8.4
Python version:      3.12.2
Git commit:          eac7892e
Built:               Thu, Aug 22, 2024 10:02 AM
OS/Arch:             darwin/arm64
Profile:             sandbox-jeff
Server type:         cloud
Pydantic version:    2.8.2


### Additional context

_No response_

discdiver avatar Aug 27 '24 16:08 discdiver