Using the default WS staging area instead of the capo property
1 unresolved thread
1 unresolved thread
Reverting the commit I previously did that was telling ingest to use the vlbiStagingDirectory capo property instead of the default stagingDirectory one.
There is now an ObservationCollector that copies everything from the drop location (e.g. difx directory) to the staging directory.
Edited by Daniel Nemergut
Merge request reports
Activity
assigned to @dnemergu
168 self.logger = logging.getLogger("ingest_envoy") 169 self.parameters = parameters 170 self.staging_source_dir = self.parameters["staging_area"] + "/" + self.parameters["workflowDir"] 171 172 def collect_products(self): 173 """ 174 Run observation product collection script 175 """ 176 self.logger.info("Collecting observation products for staging...") 177 cache_path = self.parameters["cachePath"] 178 workflow_dir = self.parameters["workflowDir"] 179 staging_dir = self.parameters["staging_area"] 180 181 # run script 182 collector = subprocess.run( 183 ["./observation-product-collector.sh", cache_path, workflow_dir, staging_dir], changed this line in version 3 of the diff
added 1 commit
- 85143fb1 - Renamed cachePath to sourcePath to make it more clear what this is
mentioned in commit ab3cca96
Please register or sign in to reply