Marty Ko
08/08/2022, 8:27 AMAnna Geller
08/08/2022, 9:23 AMMarty Ko
08/08/2022, 9:43 AMChristopher Scheidel
08/08/2022, 11:40 AMAnna Geller
08/08/2022, 11:44 AMfrom prefect import task, flow
from prefect import get_run_logger
@task
def say_hi(user_name: str):
logger = get_run_logger()
<http://logger.info|logger.info>("Hello from Prefect 2.0, %s!", user_name)
@flow
def parametrized_flow(user: str = "Marvin"):
say_hi(user)
if __name__ == "__main__":
parametrized_flow(user="Marty")
Christopher Scheidel
08/08/2022, 12:10 PMcreate_flow_run_from_deployment()
is not as straightforward as I thought.
Currently exploring the API route on this end to see if that’s a workable option for us. 🤓from prefect.client import OrionClient
import asyncio
prefect_client = OrionClient(api="http://<ip>:4200/api")
loop = asyncio.get_event_loop()
task = loop.create_task(
prefect_client.create_flow_run_from_deployment(
deployment_id="188e210d-4246-45d4-9ac2-014852b96115",
parameters={'content_id':'new_content_id'}))
loop.run_until_complete(task)
Anna Geller
08/08/2022, 12:29 PMChristopher Scheidel
08/08/2022, 12:32 PMAnna Geller
08/08/2022, 1:30 PMMarty Ko
08/09/2022, 12:39 AMYSF
09/01/2022, 9:40 PMAnna Geller
09/10/2022, 12:08 AM