@Elizabeth Bing - 🧵 for error

Traceback (most recent call last): File "/opt/homebrew/Caskroom/miniconda/base/bin/prefect", line 5, in <module> from prefect.cli import app File "/opt/homebrew/Caskroom/miniconda/base/lib/python3.11/site-packages/prefect/__init__.py", line 45, in <module> from prefect.engine import pause_flow_run, resume_flow_run File "/opt/homebrew/Caskroom/miniconda/base/lib/python3.11/site-packages/prefect/engine.py", line 98, in <module> from anyio import start_blocking_portal ImportError: cannot import name 'start_blocking_portal' from 'anyio' (/opt/homebrew/Caskroom/miniconda/base/lib/python3.11/site-packages/anyio/__init__.py)

import httpx

from prefect import flow, task import pandas as pd from prefect.tasks import task_input_hash # latitude 26.1 North, longitude 84.8 West # TASKS # cache_key determines the inputs @task(cache_key_fn=task_input_hash, cache_expiration=datetime.timedeltas=) def fetch_weather(lat: float, lon: float): base_url = "https://api.open-meteo.com/v1/forecast/" weather = httpx.get( base_url, params=dict( latitude=lat, longitude=lon, hourly="temperature_2m,cloudcover_mid,windspeed_10m,winddirection_10m", ), ) weather_json = weather.json() df = pd.DataFrame( { "latitude": weather_json["latitude"], "longitude": weather_json["longitude"], "temperature": weather.json()["hourly"]["temperature_2m"], "wind": weather.json()["hourly"]["windspeed_10m"], "cloudcover": weather.json()["hourly"]["cloudcover_mid"], } ) return df @task def save_weather_data(data: pd.DataFrame): data.to_csv("weather_data.csv") return "successfully wrote file" @task def get_latest_value(data: pd.DataFrame, metric: str): print(f"latest data for {metric} {data[metric].iloc[-1]}") # FLOW # Determines the order in which tasks are called @flow(retries=4) def get_weather_metrics(lat: float, lon: float): df = fetch_weather(lat=lat, lon=lon) # print out latest wind metric get_latest_value(df, "wind") save_weather_data(df) # Start the flow if name == "__main__": get_weather_metrics(38.9, -77.0)

Issue was a syntax error:

@task(cache_key_fn=task_input_hash, cache_expiration=datetime.timedeltas=)

Thanks for helping with the discovery of another bug/fixing team 🙂 Btw, have you come across this issue with deployment? RuntimeError: Docker worker cannot be used with an ephemeral server.

Hmm… no I haven’t seen that one. Let me take a look…

I see I see, thanks Emil!