add workdir cleanup job

geospaas_rest_api/migrations/0007_workdircleanupjob.py

@@ -0,0 +1,24 @@
+# Generated by Django 3.2 on 2024-11-18 08:27
+
+from django.db import migrations
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('geospaas_rest_api', '0006_syntoolcomparejob'),
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='WorkdirCleanupJob',
+            fields=[
+            ],
+            options={
+                'proxy': True,
+                'indexes': [],
+                'constraints': [],
+            },
+            bases=('geospaas_rest_api.job',),
+        ),
+    ]

geospaas_rest_api/models.py

@@ -10,4 +10,5 @@
                                                          ConvertJob,
                                                          SyntoolCleanupJob,
                                                          SyntoolCompareJob,
-                                                         HarvestJob)
+                                                         HarvestJob,
+                                                         WorkdirCleanupJob)

geospaas_rest_api/processing_api/models.py

@@ -317,3 +317,21 @@ def check_parameters(parameters):
     @staticmethod
     def make_task_parameters(parameters):
         return ((parameters['search_config_dict'],), {})
+
+
+class WorkdirCleanupJob(Job):
+    """Remove everything in the working directory"""
+    class Meta:
+        proxy = True
+
+    @classmethod
+    def get_signature(cls, parameters):
+        return tasks_core.cleanup_workdir.signature()
+
+    @staticmethod
+    def check_parameters(parameters):
+        return parameters
+
+    @staticmethod
+    def make_task_parameters(parameters):
+        return (tuple(), {})