Giacomo Chiarella
with prefect.get_client() as c: logs = await c.read_logs( LogFilter(task_run_id={"any_": [task.id]}, level={"ge_": "info"}) )
LogFilter(task_run_id={"any_": [task.id]}, level={"ge_": "info"})
LogFilter(task_run_id={"any_": [task.id]}, level={"le_": "info"})
task = my_task.submit(…)
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.