Suman Kamalapuram
Geese Howard
namespaceOverride: prefect worker: cloudApiConfig: accountId: HIDE workspaceId: HIDE config: workPool: gke workPool: gke-cpu-5000m-4Gi serviceAccount: create: false name: "HIDE"
Riccardo Tesselli
yu zeng
Maity
# create an api request for each self link api_results = api_get.map(map(lambda x: x["self"], employee_self_links)) @task( retries=3, retry_delay_seconds=exponential_backoff(backoff_factor=10), ) def write(employee: Response): employee = employee.json() dest = f"raw/employees/details/{employee['id']}.json" write_to_file_system.fn(dest, employee) # save the results to storage storage_results = write.map(api_results)
Tomer Friedman
OpenTelemetry
Andreas Nigg
Ahmed Ezzat
prefect 1.2.0-python3.9
Jason Prado
createFlowRun
Andrei Tulbure
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.