I set the flow schedule 5minutely by cron string. ...
# ask-communitys
Seonghwan Hong
08/31/2021, 10:06 AMI set the flow schedule 5minutely by cron string. However, the upcoming flow list is not visible in the UI. And It is not running. Prefect doesn't actually run the flow at the time.
k
Kevin Kho
08/31/2021, 1:38 PM
Hi @Seonghwan Hong, can you try turning off the schedule then turning it on again?
s
Seonghwan Hong
09/01/2021, 2:19 AMI turned off and turned on my schedule but it doesn't solve this problem..
k
Kevin Kho
09/01/2021, 2:29 AM
Could you show me how you attached your schedule?
Kevin Kho
09/01/2021, 2:30 AM
Not related to your question but I am just cruious, is this a prediction flow? BERT + Spark every 5 minutes seems very heavy
Kevin Kho
09/01/2021, 2:49 AM
I suspect you are passing a parameter that is not JSONSerializable into your schedule
s
Seonghwan Hong
09/01/2021, 3:28 AMIt is for embedding all korean news article and advertise content BERT embedding.
We using prefect Schedule module. You can see the attached code.
Seonghwan Hong
09/01/2021, 3:34 AMI think JSONSerializable issue is not reason of this problem. Because I remove the code that attaching schedule, and I register schedule in prefect UI server by myself, then it worked well now
k
Kevin Kho
09/01/2021, 3:39 AM
Will try this now
Kevin Kho
09/01/2021, 3:46 AM
Hey, I tried this and I see scheduled flow runs in the UI.
Copy code
from prefect.schedules import CronSchedule
from prefect import Flow, task
@task
def abc():
return 1
with Flow("test_sched") as flow:
abc()
flow.schedule = CronSchedule("0,5,10,15,20,25,30,35,40,45,55 * * * *")
flow.register("dsdc")Kevin Kho
09/01/2021, 3:48 AM
I get the same schedule you got so Iām not sure what it could be at this point.
s
Seonghwan Hong
09/01/2021, 6:28 AMthank you!.. I will try again
k
Kevin Kho
09/01/2021, 2:50 PM
I can dig further if you can give me a small example
s
Seonghwan Hong
09/03/2021, 7:37 AMI think it is because we delete flow run history in our postgresql server by below query.
Copy code
delete from flow_run_state where updated <= '2021-08-15';
delete from log where updated <= '2021-08-01';
delete from task_run_state where updated <= '2021-08-15';
delete from task_run where updated >= '2021-06-20' and updated<='2021-08-15';
delete from flow_run where updated <= '2021-08-15';
vacuum verbose analyze;š 1
k
Kevin Kho
09/03/2021, 1:45 PM
Ah I see