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

class Demo:
    def demo1(self, a: int, b: int) -> int:
        value = a+ b

    def demo2(self, a: int, b: int) -> int:
        return a+b

obj = Demo()
demo1_function = task(Demo.demo1)
demo2_function = task(Demo.demo2)

with Flow("demo-flow") as flow:
    params = {"a": 1, "b": 2}
    demo1_function(obj, **params)
    demo2_function(obj, **params)

start_time = datetime.now() - timedelta(hours=5)
interval_time = timedelta(hours=0, minutes=1, seconds=0)
end_time = datetime.strptime("2022-12-31 23:59:00", "%Y-%m-%d %H:%M:%S")

schedule = IntervalSchedule(
    start_date = start_time,
    interval=interval_time,
    end_date=end_time
    )

flow.run()
flow.schedule = schedule
flow_id = flow.register(project_name="test",
              labels=['Suleman'],
              idempotency_key=flow.serialized_hash())

self