Skip to content
Snippets Groups Projects
Commit 85143fb1 authored by Daniel Nemergut's avatar Daniel Nemergut
Browse files

Renamed cachePath to sourcePath to make it more clear what this is

parent 5fa25feb
No related branches found
No related tags found
2 merge requests!1452Merge 2.8.2 to main,!1446Using the default WS staging area instead of the capo property
Pipeline #11533 passed
......@@ -144,7 +144,7 @@ class SECICollector(CollectorIF):
:return:
"""
self.logger.info("Collecting SECI products for staging...")
cache_path = self.parameters["cachePath"]
cache_path = self.parameters["sourcePath"]
workflow_dir = self.parameters["workflowDir"]
staging_dir = self.parameters["staging_area"]
tar_name = self.create_artifacts_name()
......@@ -174,13 +174,13 @@ class ObservationCollector(CollectorIF):
Run observation product collection script
"""
self.logger.info("Collecting observation products for staging...")
cache_path = self.parameters["cachePath"]
source_path = self.parameters["sourcePath"]
workflow_dir = self.parameters["workflowDir"]
staging_dir = self.parameters["staging_area"]
# run script
collector = subprocess.run(
["./observation-product-collector.sh", cache_path, workflow_dir, staging_dir],
["./observation-product-collector.sh", source_path, workflow_dir, staging_dir],
stdout=sys.stdout,
stderr=sys.stderr,
)
......
......@@ -65,7 +65,7 @@ def _get_settings(
parameters["calSpl"] = cal_spl
if source_dir is not None:
parameters["workflowDir"] = pathlib.Path(source_dir).name
parameters["cachePath"] = pathlib.Path(source_dir).parent
parameters["sourcePath"] = pathlib.Path(source_dir).parent
parameters["staging_area"] = ingestion_settings.stagingDirectory
parameters["storage_area"] = ingestion_settings.storageDirectory
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment