Skip to content
Snippets Groups Projects
Commit cad13a89 authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

TMSS: make dataproduct file/dir names conform lofar naming standards

parent 39f64d7f
Branches
No related tags found
No related merge requests found
...@@ -208,7 +208,9 @@ def _populate_example_data(): ...@@ -208,7 +208,9 @@ def _populate_example_data():
subtask_output = models.SubtaskOutput.objects.create(**SubtaskOutput_test_data(subtask=subtask)) subtask_output = models.SubtaskOutput.objects.create(**SubtaskOutput_test_data(subtask=subtask))
for sb_nr in specifications_doc['stations']['digital_pointings'][0]['subbands']: for sb_nr in specifications_doc['stations']['digital_pointings'][0]['subbands']:
models.Dataproduct.objects.create(**Dataproduct_test_data(producer=subtask_output, filename="test_dataproduct_SB_%03d.MS"%sb_nr)) models.Dataproduct.objects.create(**Dataproduct_test_data(producer=subtask_output,
directory="CEP4:/data/test-projects/L%d/uv/" % (subtask.id,),
filename="L%d_SB%03d_uv.MS"%(subtask.id, sb_nr)))
except ImportError: except ImportError:
pass pass
......
...@@ -281,7 +281,7 @@ def Subtask_test_data(task_blueprint: models.TaskBlueprint=None, subtask_templat ...@@ -281,7 +281,7 @@ def Subtask_test_data(task_blueprint: models.TaskBlueprint=None, subtask_templat
def Dataproduct_test_data(producer: models.SubtaskOutput=None, def Dataproduct_test_data(producer: models.SubtaskOutput=None,
filename: str="my_file.ext", filename: str="my_file.ext",
directory: str="head.cep4.control.lofar:/data/test-projects", directory: str="CEP4:/data/test-projects",
dataformat: models.Dataformat=None) -> dict: dataformat: models.Dataformat=None) -> dict:
if producer is None: if producer is None:
producer = models.SubtaskOutput.objects.create(**SubtaskOutput_test_data()) producer = models.SubtaskOutput.objects.create(**SubtaskOutput_test_data())
...@@ -292,13 +292,13 @@ def Dataproduct_test_data(producer: models.SubtaskOutput=None, ...@@ -292,13 +292,13 @@ def Dataproduct_test_data(producer: models.SubtaskOutput=None,
return {"filename": filename, return {"filename": filename,
"directory": directory, "directory": directory,
"dataformat": dataformat, "dataformat": dataformat,
"deleted_since": datetime.utcnow().isoformat(), "deleted_since": None,
"pinned_since": datetime.utcnow().isoformat(), "pinned_since": None,
"specifications_doc": "{}", "specifications_doc": "{}",
"specifications_template": models.DataproductSpecificationsTemplate.objects.create(**DataproductSpecificationsTemplate_test_data()), "specifications_template": models.DataproductSpecificationsTemplate.objects.create(**DataproductSpecificationsTemplate_test_data()),
"tags": ["TMSS", "TESTING"], "tags": ["TMSS", "TESTING"],
"producer": producer, "producer": producer,
"do_cancel": datetime.utcnow().isoformat(), "do_cancel": None,
"expected_size": 1234, "expected_size": 1234,
"size": 123, "size": 123,
"feedback_doc": "{}", "feedback_doc": "{}",
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment