fix: Disable observing fetch results for now (#24219)

PostHog · Aug 6, 2024 · f676483 · f676483
1 parent 4f35a7e
commit f676483
Showing 1 changed file with 2 additions and 24 deletions.
diff --git a/plugin-server/src/cdp/cdp-consumers.ts b/plugin-server/src/cdp/cdp-consumers.ts
@@ -257,36 +257,14 @@ abstract class CdpConsumerBase {
         return await runInstrumentedFunction({
             statsKey: `cdpConsumer.handleEachBatch.executeAsyncResponses`,
             func: async () => {
-                this.hogWatcher.currentObservations.observeAsyncFunctionResponses(asyncResponses)
+                // NOTE: Disabled for now as it needs some rethinking
+                // this.hogWatcher.currentObservations.observeAsyncFunctionResponses(asyncResponses)
                 asyncResponses.forEach((x) => {
                     counterAsyncFunctionResponse.inc({
                         outcome: x.asyncFunctionResponse.error ? 'failed' : 'succeeded',
                     })
                 })
 
-                // Filter for blocked functions
-                const asyncResponsesToRun: HogFunctionInvocationAsyncResponse[] = []
-
-                for (const item of asyncResponses) {
-                    const functionState = this.hogWatcher.getFunctionState(item.hogFunctionId)
-
-                    if (functionState > HogWatcherState.disabledForPeriod) {
-                        this.produceAppMetric({
-                            team_id: item.teamId,
-                            app_source_id: item.hogFunctionId,
-                            metric_kind: 'failure',
-                            metric_name:
-                                functionState === HogWatcherState.disabledForPeriod
-                                    ? 'disabled_temporarily'
-                                    : 'disabled_permanently',
-                            count: 1,
-                        })
-                        continue
-                    } else {
-                        asyncResponsesToRun.push(item)
-                    }
-                }
-
                 const invocationsWithResponses: [HogFunctionInvocation, HogFunctionAsyncFunctionResponse][] = []
 
                 // Deserialize the compressed data