diff --git a/SAS/TMSS/src/tmss/tmssapp/populate.py b/SAS/TMSS/src/tmss/tmssapp/populate.py index 8a7e9ecef7a27b3cbd96e1963cd543701aafeb78..3916b8df40b61249b54d8bb4f35b8061de96addf 100644 --- a/SAS/TMSS/src/tmss/tmssapp/populate.py +++ b/SAS/TMSS/src/tmss/tmssapp/populate.py @@ -153,12 +153,38 @@ def populate_resources(apps, schema_editor): ResourceType.objects.create(name="observing_time_commissioning", description="Observing time for Commissioning/DDT (in seconds)", quantity=Quantity.objects.get(value=Quantity.Choices.TIME.value)) ResourceType.objects.create(name="support_time", description="Support time by human (in seconds)", quantity=Quantity.objects.get(value=Quantity.Choices.TIME.value)) ResourceType.objects.create(name="number_of_triggers", description="Number of trigger events (as integer)", quantity=Quantity.objects.get(value=Quantity.Choices.NUMBER.value)) + # TODO these duplicates have names that front-end expects. + # TODO We should not have doubles. + ResourceType.objects.create(name="LTA Storage", description="Amount of storage in the LTA (in bytes)", quantity=Quantity.objects.get(value=Quantity.Choices.BYTES.value)) + ResourceType.objects.create(name="CEP Storage", description="Amount of storage on the CEP processing cluster (in bytes)", quantity=Quantity.objects.get(value=Quantity.Choices.BYTES.value)) + ResourceType.objects.create(name="CEP Processing Time", description="Processing time on the CEP processing cluster (in seconds)", quantity=Quantity.objects.get(value=Quantity.Choices.TIME.value)) + ResourceType.objects.create(name="LOFAR Observing Time", description="Observing time (in seconds)", quantity=Quantity.objects.get(value=Quantity.Choices.TIME.value)) + ResourceType.objects.create(name="LOFAR Observing Time prio A", description="Observing time with priority A (in seconds)", quantity=Quantity.objects.get(value=Quantity.Choices.TIME.value)) + ResourceType.objects.create(name="LOFAR Observing Time prio B", description="Observing time with priority B (in seconds)", quantity=Quantity.objects.get(value=Quantity.Choices.TIME.value)) + ResourceType.objects.create(name="LOFAR Observing Time Commissioning", description="Observing time for Commissioning/DDT (in seconds)", quantity=Quantity.objects.get(value=Quantity.Choices.TIME.value)) + ResourceType.objects.create(name="LOFAR Support Time", description="Support time by human (in seconds)", quantity=Quantity.objects.get(value=Quantity.Choices.TIME.value)) + ResourceType.objects.create(name="Number of triggers", description="Number of trigger events (as integer)", quantity=Quantity.objects.get(value=Quantity.Choices.NUMBER.value)) def populate_misc(apps, schema_editor): cluster = Cluster.objects.create(name="CEP4", location="CIT", archive_site=False) fs = Filesystem.objects.create(name="LustreFS", cluster=cluster, capacity=3.6e15) + sara_cluster = Cluster.objects.create(name="SARA", location="SARA", archive_site=True) + juelich_cluster = Cluster.objects.create(name="Jülich", location="Jülich", archive_site=True) + poznan_cluster = Cluster.objects.create(name="Poznan", location="Poznan", archive_site=True) + + sara_fs = Filesystem.objects.create(name="Lofar Storage (SARA)", cluster=sara_cluster, capacity=3.6e15, + directory="srm://srm.grid.sara.nl:8443/pnfs/grid.sara.nl/data/lofar/ops/projects/") + sara_test_fs = Filesystem.objects.create(name="Lofar Test Storage (SARA)", cluster=sara_cluster, capacity=3.6e15, + directory="srm://srm.grid.sara.nl:8443/pnfs/grid.sara.nl/data/lofar/ops/test/projects/") + sara_user_fs = Filesystem.objects.create(name="Lofar User Disk Storage (SARA)", cluster=sara_cluster, capacity=3.6e15, + directory="srm://srm.grid.sara.nl/pnfs/grid.sara.nl/data/lofar/user/disk/projects/") + juelich_fs = Filesystem.objects.create(name="Lofar Storage (Jülich)", cluster=juelich_cluster, capacity=3.6e15, + directory="srm://lofar-srm.fz-juelich.de:8443/pnfs/fz-juelich.de/data/lofar/ops/projects/") + pozname_fs = Filesystem.objects.create(name="Lofar Storage (Poznan)", cluster=poznan_cluster, capacity=3.6e15, + directory="srm://lta-head.lofar.psnc.pl:8443/lofar/ops/projects/") + def populate_connectors(): # the TaskConnectorType's define how the Task[Draft/Blueprint] *can* be connected. @@ -171,4 +197,4 @@ def populate_connectors(): TaskConnectorType.objects.create(role=Role.objects.get(value=Role.Choices.CORRELATOR.value), datatype=Datatype.objects.get(value=Datatype.Choices.VISIBILITIES.value), output_of=TaskTemplate.objects.get(name='calibrator observation'), - input_of=TaskTemplate.objects.get(name='preprocessing pipeline')) \ No newline at end of file + input_of=TaskTemplate.objects.get(name='preprocessing pipeline'))