File tree Expand file tree Collapse file tree 4 files changed +5
-3
lines changed Expand file tree Collapse file tree 4 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -29,7 +29,8 @@ def get_activity_notifiers(project):
29
29
queue = "activity.notify" ,
30
30
silo_mode = SiloMode .REGION ,
31
31
taskworker_config = TaskworkerConfig (
32
- namespace = notifications_tasks , processing_deadline_duration = 60
32
+ namespace = notifications_tasks ,
33
+ processing_deadline_duration = 120 ,
33
34
),
34
35
)
35
36
def send_activity_notifications (activity_id : int ) -> None :
Original file line number Diff line number Diff line change @@ -31,6 +31,7 @@ def paginate_project_ids(paginate):
31
31
silo_mode = SiloMode .REGION ,
32
32
taskworker_config = TaskworkerConfig (
33
33
namespace = issues_tasks ,
34
+ processing_deadline_duration = 30 ,
34
35
),
35
36
)
36
37
def collect_project_platforms (paginate = 1000 , ** kwargs ):
Original file line number Diff line number Diff line change @@ -48,7 +48,7 @@ def schedule_digests() -> None:
48
48
silo_mode = SiloMode .REGION ,
49
49
taskworker_config = TaskworkerConfig (
50
50
namespace = digests_tasks ,
51
- processing_deadline_duration = 10 * 60 ,
51
+ processing_deadline_duration = 15 * 60 ,
52
52
),
53
53
)
54
54
def deliver_digest (
Original file line number Diff line number Diff line change @@ -161,7 +161,7 @@ def _process_suspect_commits(
161
161
silo_mode = SiloMode .REGION ,
162
162
taskworker_config = TaskworkerConfig (
163
163
namespace = issues_tasks ,
164
- processing_deadline_duration = 20 ,
164
+ processing_deadline_duration = 60 ,
165
165
retry = Retry (
166
166
times = 5 ,
167
167
delay = 5 ,
You can’t perform that action at this time.
0 commit comments