File tree Expand file tree Collapse file tree 3 files changed +2
-3
lines changed Expand file tree Collapse file tree 3 files changed +2
-3
lines changed Original file line number Diff line number Diff line change 9
9
from fastapi_cloud_tasks .utils import location_path
10
10
from fastapi_cloud_tasks .utils import queue_path
11
11
12
- TASK_LISTENER_BASE_URL = os .getenv ("TASK_LISTENER_BASE_URL" , default = "https://65fb -35-207-241-4.ngrok.io" )
12
+ TASK_LISTENER_BASE_URL = os .getenv ("TASK_LISTENER_BASE_URL" , default = "https://645e -35-207-241-4.ngrok.io" )
13
13
TASK_PROJECT_ID = os .getenv ("TASK_PROJECT_ID" , default = "sample-project" )
14
14
TASK_LOCATION = os .getenv ("TASK_LOCATION" , default = "asia-south1" )
15
15
SCHEDULED_LOCATION = os .getenv ("SCHEDULED_LOCATION" , default = "us-central1" )
Original file line number Diff line number Diff line change @@ -75,7 +75,7 @@ async def scheduled_hello(p: Payload = Payload(message="Default")):
75
75
76
76
scheduled_hello .scheduler (
77
77
name = "testing-examples-scheduled-hello" ,
78
- schedule = "* * * * *" ,
78
+ schedule = "*/5 * * * *" ,
79
79
time_zone = "Asia/Kolkata" ,
80
80
).schedule (p = Payload (message = "Scheduled" ))
81
81
Original file line number Diff line number Diff line change @@ -80,7 +80,6 @@ def schedule(self, **kwargs):
80
80
request = self .pre_create_hook (request )
81
81
82
82
if self .force or self ._has_changed (request = request ):
83
- print ("Changed" )
84
83
# Delete and create job
85
84
self .delete ()
86
85
self .client .create_job (request = request , timeout = self .job_create_timeout )
You can’t perform that action at this time.
0 commit comments