hello_world.py

hello_world.py

from prefect import task, Flow
from prefect.schedules import IntervalSchedule
from datetime import timedelta, datetime


@task(log_stdout=True)
def say_hello():
    print("Hello world!")


def main():
    schedule = IntervalSchedule(
        start_date=datetime.utcnow() + timedelta(seconds=1),
        interval=timedelta(minutes=1),
    )

    with Flow("hello_world", schedule=schedule) as flow:
        say_hello()
   
    flow.register(project_name="test")
    print('done')


if __name__ == "__main__":
    main()

query Api {
  api {
    backend
    mode
    version
    core_version
    release_timestamp
  }
}

--use-volume