From 8610e28acf9aefc0da33c2e93961c9065b4b5a9f Mon Sep 17 00:00:00 2001 From: Adam Azzam <33043305+aaazzam@users.noreply.github.com> Date: Wed, 7 May 2025 22:24:33 -0400 Subject: [PATCH] Update 01_getting_started.py --- 01_getting_started.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/01_getting_started.py b/01_getting_started.py index 049b084..8333dfa 100644 --- a/01_getting_started.py +++ b/01_getting_started.py @@ -1,6 +1,8 @@ from prefect import flow, task +from prefect.logger import get_run_logger import random + @task def get_customer_ids() -> list[str]: # Fetch customer IDs from a database or API @@ -9,6 +11,9 @@ def get_customer_ids() -> list[str]: @task def process_customer(customer_id: str) -> str: # Process a single customer + logger = get_run_logger() + for _ in range(50): + logger.info(f"Processing customer {customer_id}") return f"Processed {customer_id}" @flow