Hampus Rosvall
09/28/2022, 2:09 PMimport typing, logging
from flytekit import (
task,
workflow,
LaunchPlan,
)
logging.basicConfig(level=<http://logging.INFO|logging.INFO>, format='%(asctime)s %(levelname)s %(message)s')
@task
def hello():
<http://logging.info|logging.info>("Hello!")
@task
def world():
<http://logging.info|logging.info>("World!")
@workflow
def wf() -> None:
hello()
world()
return
LaunchPlan.get_or_create(
workflow=wf,
name="flytesnacks_lp",
default_inputs={},
)
Shivay Lamba
09/28/2022, 2:14 PMKetan (kumare3)
Hampus Rosvall
09/29/2022, 6:35 AM