Skip to content
Snippets Groups Projects

integrate curator with envoy for workflow

Merged Charlotte Hausman requested to merge curator-integration into 2.8.2.1-DEVELOMENT
2 files
+ 3
3
Compare changes
  • Side-by-side
  • Inline
Files
2
@@ -43,6 +43,7 @@ from ingest_envoy.manifest_components import (
ManifestParameters,
OutputGroup,
OutputScienceProduct,
ParamsKey,
)
from ingest_envoy.utilities import AncillaryProductType, ScienceProductType, Telescope
@@ -88,7 +89,7 @@ def test_filters_cal_input_files(ingest_path: Path):
assert manifest.locator == locator
params = manifest.parameters
assert params.reingest is False and params.ngas_ingest is True
assert params.ngas_ingest is True
assert not hasattr(params, "calibrate")
input_group = manifest.input_group
@@ -162,7 +163,6 @@ def test_params_json_well_formed():
"""
params = ManifestParameters(
telescope=Telescope.EVLA,
reingest=False,
ngas_ingest=False,
calibrate=False,
staging_source_dir=Path("/home/mchammer/evla/parallel-prod"),
@@ -331,13 +331,11 @@ def test_evla_cal_manifest_matches_example(ingest_path: Path):
with open(manifest_file, "r") as infile:
actual_json = dict(json.load(infile).items())
actual_json[IngestionManifestKey.PARAMETERS.value][IngestionManifestKey.INGESTION_PATH.value] = expected_dir_name
actual_json[IngestionManifestKey.PARAMETERS.value][ParamsKey.INGESTION_PATH.value] = expected_dir_name
expected_params = expected_json["parameters"]
actual_params = manifest.parameters.to_dict()
expected_reingest = expected_params["reingest"]
assert actual_params["reingest"] == expected_reingest
expected_ngas_ingest = expected_params["ngas_ingest"]
assert actual_params["ngas_ingest"] == expected_ngas_ingest
@@ -435,13 +433,11 @@ def test_evla_cal_final_manifest_matches_example(ingest_path: Path):
with open(manifest_file, "r") as infile:
actual_json = dict(json.load(infile).items())
actual_json[IngestionManifestKey.PARAMETERS.value][IngestionManifestKey.INGESTION_PATH.value] = expected_dir_name
actual_json[IngestionManifestKey.PARAMETERS.value][ParamsKey.INGESTION_PATH.value] = expected_dir_name
expected_params = expected_json["parameters"]
actual_params = manifest.parameters.to_dict()
expected_reingest = expected_params["reingest"]
assert actual_params["reingest"] == expected_reingest
expected_ngas_ingest = expected_params["ngas_ingest"]
assert actual_params["ngas_ingest"] == expected_ngas_ingest
Loading