Valantis Hatzimagkas
03/03/2022, 10:08 AMAbhishek
03/03/2022, 10:11 AMValantis Hatzimagkas
03/03/2022, 10:19 AMfrom prefect import task, Flow, prefect
from prefect.storage import Docker
import requests
lat = 40
lon = 45
API_key = 'my_key'
url = f'<https://api.openweathermap.org/data/2.5/weather?lat={lat}&lon={lon}&appid={API_key}>'
@task
def get_weather():
return requests.get(url).json()
@task
def logger(res):
for k, v in res['main'].items():
print(f'{k}: {v}')
with Flow('spray_service') as flow:
data = get_weather()
logger(data)
if __name__ == "__main__":
flow.storage = Docker(image_name="my_image", image_tag="latest", local_image=True,
dockerfile='Dockerfile')
#flow.register('test')
flow.run()
Anna Geller
Valantis Hatzimagkas
03/03/2022, 11:31 AMFROM prefecthq/prefect:0.15.13-python3.9
But! my flow was serialized in *python 3.10(During registration prefect complained about this,* but silly me I did not notice it*)*
This caused this strange issue in my caseAnna Geller