prefect
prefect copied to clipboard
Flow run errors frequently with `prefect._internal.concurrency - Service 'EventsWorker' failed to process item`
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_