Skip to content

Commit

Permalink
chore(data-warehouse): Removed pipeline dir (#23011)
Browse files Browse the repository at this point in the history
Removed pipeline dir
  • Loading branch information
Gilbert09 authored Jun 17, 2024
1 parent 5590230 commit b094d50
Showing 1 changed file with 0 additions and 15 deletions.
15 changes: 0 additions & 15 deletions posthog/temporal/data_imports/pipelines/pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@

from asgiref.sync import async_to_sync
import asyncio
import os
from posthog.settings.base_variables import TEST
from structlog.typing import FilteringBoundLogger
from dlt.sources import DltSource
Expand Down Expand Up @@ -55,18 +54,6 @@ def _get_pipeline_name(self):

return f"{base}_{self.inputs.run_id}"

@property
def _get_pipelines_dir_base(self):
return f"{os.getcwd()}/.dlt/{self.inputs.team_id}"

def _get_pipelines_dir(self):
base = self._get_pipelines_dir_base

if self._incremental:
return f"{base}/{self.inputs.source_id}/{self.inputs.job_type}"

return f"{base}/{self.inputs.run_id}/{self.inputs.job_type}"

def _get_destination(self):
if TEST:
credentials = {
Expand All @@ -88,12 +75,10 @@ def _get_destination(self):

def _create_pipeline(self):
pipeline_name = self._get_pipeline_name()
pipelines_dir = self._get_pipelines_dir()
destination = self._get_destination()

return dlt.pipeline(
pipeline_name=pipeline_name,
pipelines_dir=pipelines_dir,
destination=destination,
dataset_name=self.inputs.dataset_name,
)
Expand Down

0 comments on commit b094d50

Please sign in to comment.