remove unnecessary

PostHog · Dec 11, 2023 · dde79e0 · dde79e0
1 parent 964cd6f
commit dde79e0
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/posthog/temporal/data_imports/pipelines/stripe/stripe_pipeline.py b/posthog/temporal/data_imports/pipelines/stripe/stripe_pipeline.py
@@ -65,10 +65,6 @@ def create_pipeline(inputs: PipelineInputs):
     )
 
 
-def run_pipeline(pipeline, gen):
-    pipeline.run(gen())
-
-
 # a temporal activity
 async def run_stripe_pipeline(inputs: StripeJobInputs) -> None:
     logger = await bind_temporal_worker_logger(team_id=inputs.team_id)