Skip to content
Snippets Groups Projects

Using the default WS staging area instead of the capo property

Merged Daniel Nemergut requested to merge ws1808-ingest_obs_staging_changes into 2.8.2-DEVELOPMENT
1 unresolved thread
2 files
+ 4
4
Compare changes
  • Side-by-side
  • Inline
Files
2
@@ -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,
)
Loading