chore(taskworker): Bump processing deadlines in tasks (#93606)

This PR bumps the processing deadlines for the following tasks

Refs: 
-
https://sentry.sentry.io/issues/6680339419/?project=1&query=is%3Aunresolved%20taskworker&referrer=issue-stream&stream_index=2
-
https://sentry.sentry.io/issues/6680996158/?project=1&query=is%3Aunresolved%20taskworker&referrer=issue-stream&stream_index=0
-
https://sentry.sentry.io/issues/6673930303/?project=1&query=is%3Aunresolved%20taskworker&referrer=issue-stream&stream_index=5
-
https://sentry.sentry.io/issues/6683037862/?project=1&query=is%3Aunresolved%20taskworker&referrer=issue-stream&stream_index=12
-
https://sentry.sentry.io/issues/6678586192/?project=1&query=is%3Aunresolved%20taskworker&referrer=issue-stream&stream_index=1
-
https://sentry.sentry.io/issues/6682379577/?project=1&query=is%3Aunresolved%20taskworker&referrer=issue-stream&stream_index=7
-
https://sentry.sentry.io/issues/6678740537/?project=1&query=is%3Aunresolved%20taskworker&referrer=issue-stream&stream_index=6
-
https://sentry.sentry.io/issues/6679275182/?project=1&query=is%3Aunresolved%20taskworker&referrer=issue-stream&stream_index=11

Author: enochtangg

src/sentry/integrations/source_code_management/tasks.py

@@ -184,6 +184,7 @@ def pr_comment_workflow(pr_id: int, project_id: int):
     silo_mode=SiloMode.REGION,
     taskworker_config=TaskworkerConfig(
         namespace=integrations_tasks,
+        processing_deadline_duration=150,
     ),
 )
 def open_pr_comment_workflow(pr_id: int) -> None:

src/sentry/integrations/tasks/sync_status_inbound.py

@@ -193,6 +193,7 @@ def group_was_recently_resolved(group: Group) -> bool:
     default_retry_delay=60 * 5,
     max_retries=5,
     silo_mode=SiloMode.REGION,
+    processing_deadline_duration=150,
     taskworker_config=TaskworkerConfig(
         namespace=integrations_tasks,
         retry=Retry(

src/sentry/release_health/tasks.py

@@ -57,6 +57,7 @@ def monitor_release_adoption(**kwargs) -> None:
             on=(Exception,),
             delay=5,
         ),
+        processing_deadline_duration=150,
     ),
 )
 def process_projects_with_sessions(org_id, project_ids) -> None:

src/sentry/sentry_apps/tasks/sentry_apps.py

@@ -132,6 +132,7 @@ def _webhook_event_data(
             times=3,
             delay=60 * 5,
         ),
+        processing_deadline_duration=20,
     ),
     **TASK_OPTIONS,
 )
@@ -412,6 +413,7 @@ def _does_project_filter_allow_project(service_hook_id: int, project_id: int) ->
             times=3,
             delay=60 * 5,
         ),
+        processing_deadline_duration=150,
     ),
     **TASK_OPTIONS,
 )

src/sentry/tasks/codeowners/code_owners_auto_sync.py

@@ -25,6 +25,7 @@
             times=1,
             delay=60 * 5,
         ),
+        processing_deadline_duration=60,
     ),
 )
 @retry(on=(Commit.DoesNotExist,))

src/sentry/tasks/statistical_detectors.py

@@ -330,6 +330,7 @@ def query_timeseries(
     max_retries=0,
     taskworker_config=TaskworkerConfig(
         namespace=performance_tasks,
+        processing_deadline_duration=30,
     ),
 )
 def detect_transaction_trends(

src/sentry/uptime/detectors/tasks.py

@@ -121,6 +121,7 @@ def process_detection_bucket(bucket: str):
     queue="uptime",
     taskworker_config=TaskworkerConfig(
         namespace=uptime_tasks,
+        processing_deadline_duration=20,
     ),
 )
 def process_organization_url_ranking(organization_id: int):