Make path to pipline code an importable parameter

Author: drw

countpipe.py

@@ -15,7 +15,8 @@
 from marshmallow import fields, pre_dump, pre_load
 from pprint import pprint
 
-sys.path.insert(0, '/home/david/wprdc-etl') # A path that we need to import code from
+from parameters.local_parameters import PATH_TO_PIPELINE
+sys.path.insert(0, PATH_TO_PIPELINE)
 import pipeline as pl # This comes from the wprdc-etl repository.
 
 from notify import send_to_slack

leasepipe.py

@@ -15,7 +15,8 @@
 from marshmallow import fields, pre_dump, pre_load
 from pprint import pprint
 
-sys.path.insert(0, '/home/david/wprdc-etl') # A path that we need to import code from
+from parameters.local_parameters import PATH_TO_PIPELINE
+sys.path.insert(0, PATH_TO_PIPELINE)
 import pipeline as pl # This comes from the wprdc-etl repository.
 
 from notify import send_to_slack

pipe/pipe_to_CKAN_resource.py

@@ -7,8 +7,9 @@
 
 from datetime import datetime
 
-sys.path.insert(0, '/home/david/wprdc-etl') # A path that we need to import code from
-import pipeline as pl
+from parameters.local_parameters import PATH_TO_PIPELINE
+sys.path.insert(0, PATH_TO_PIPELINE)
+import pipeline as pl # This comes from the wprdc-etl repository.
 
 from marshmallow import fields, post_load, pre_load
 from collections import OrderedDict, defaultdict

pipelines.py

@@ -14,7 +14,8 @@
 import datetime
 from marshmallow import fields, pre_dump, pre_load
 
-sys.path.insert(0, '/home/david/wprdc-etl') # A path that we need to import code from
+from parameters.local_parameters import PATH_TO_PIPELINE
+sys.path.insert(0, PATH_TO_PIPELINE)
 import pipeline as pl # This comes from the wprdc-etl repository.
 
 from fetch_terminals import pull_terminals, csv_file_path

reupload.py

@@ -16,9 +16,9 @@
 from collections import OrderedDict, defaultdict
 from pprint import pprint
 
-sys.path.insert(0, '/home/david/wprdc-etl') # A path that we need to import code from
-import pipeline as pl
-
+from parameters.local_parameters import PATH_TO_PIPELINE
+sys.path.insert(0, PATH_TO_PIPELINE)
+import pipeline as pl # This comes from the wprdc-etl repository.
 
 class SplitTransactionsSchemaUp(BaseTransactionsSchema):
     """The split transactions schema handles the case where transactions are to be split between

upload_meter_archive.py

@@ -11,7 +11,8 @@
 
 from parameters.local_parameters import SETTINGS_FILE, base_monthly_meters_archive
 
-sys.path.insert(0, '/home/david/wprdc-etl') # A path that we need to import code from
+from parameters.local_parameters import PATH_TO_PIPELINE
+sys.path.insert(0, PATH_TO_PIPELINE)
 import pipeline as pl # This comes from the wprdc-etl repository.
 
 server = "meters-etl"