On task mark as success, still inner loops are in progress

Archive
,
8

Reply to : We are trying to run simple task using client with key and schedule datetime, its appearing duplicate in prefect cloud console, one with schedule time and one immediate.

schedule_2 = Schedule(

clocks=[DatesClock([pendulum.now().add(minutes=5)])]

)

# schedule = IntervalSchedule(interval=timedelta(minutes=2))

@task
def check_schedule():
    print("success")
    
with Flow("gaurav",schedule=schedule_2) as flow_2:
    check_schedule()
    
flow_2.register(project_name="amoga",idempotency_key=flow_2.serialized_hash())

Running flow

client = Client(api_key="api_key")
flow_run_id = client.create_flow_run(
                "b3f55da7-262f-4cad-90d7-465705a6c70b",
                labels="amoga")
print(flow_run_id)

image
image1892×827 106 KB

Manual state change to success but still the inner task is in pending state
What do you mean by state change ??? is it only of make colour change or any implementation is there
related to it