diff --git a/project/pipeline/pipeline.py b/project/pipeline/pipeline.py index 634dfe58fe..260fc962c8 100644 --- a/project/pipeline/pipeline.py +++ b/project/pipeline/pipeline.py @@ -11,6 +11,7 @@ import etl.transform.sdg_transformer as sdg_t from etl.load import loader + class Pipeline: def __extract(self): """ @@ -139,6 +140,7 @@ def run_pipeline(self): ) return - + + if __name__ == "__main__": Pipeline().run_pipeline()