fix(temporal): revert "feat(temporal): Added posthog client to tempor…

…al to enable exceptions capture" (#27236)
PostHog · Jan 3, 2025 · 2f05e8c · 2f05e8c
1 parent f76be70
commit 2f05e8c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 58 deletions.
diff --git a/posthog/temporal/common/posthog_client.py b/posthog/temporal/common/posthog_client.py
diff --git a/posthog/temporal/common/worker.py b/posthog/temporal/common/worker.py
@@ -8,7 +8,6 @@
 
 from posthog.constants import DATA_WAREHOUSE_TASK_QUEUE_V2
 from posthog.temporal.common.client import connect
-from posthog.temporal.common.posthog_client import PostHogClientInterceptor
 from posthog.temporal.common.sentry import SentryInterceptor
 
 
@@ -36,7 +35,6 @@ async def start_worker(
         client_key,
         runtime=runtime,
     )
-
     if task_queue == DATA_WAREHOUSE_TASK_QUEUE_V2:
         worker = Worker(
             client,
@@ -45,7 +43,7 @@ async def start_worker(
             activities=activities,
             workflow_runner=UnsandboxedWorkflowRunner(),
             graceful_shutdown_timeout=timedelta(minutes=5),
-            interceptors=[SentryInterceptor(), PostHogClientInterceptor()],
+            interceptors=[SentryInterceptor()],
             activity_executor=ThreadPoolExecutor(max_workers=max_concurrent_activities or 50),
             # Only run one workflow at a time
             max_concurrent_activities=1,
@@ -61,7 +59,7 @@ async def start_worker(
             activities=activities,
             workflow_runner=UnsandboxedWorkflowRunner(),
             graceful_shutdown_timeout=timedelta(minutes=5),
-            interceptors=[SentryInterceptor(), PostHogClientInterceptor()],
+            interceptors=[SentryInterceptor()],
             activity_executor=ThreadPoolExecutor(max_workers=max_concurrent_activities or 50),
             max_concurrent_activities=max_concurrent_activities or 50,
             max_concurrent_workflow_tasks=max_concurrent_workflow_tasks,