diff --git a/atdb/taskdatabase/services/activities_handler.py b/atdb/taskdatabase/services/activities_handler.py
index 790f3e53eb16c39f7840b1353c74007de1c39ddb..71eb44f5f57c1a6b6cf19180edca61e5cce44c9e 100644
--- a/atdb/taskdatabase/services/activities_handler.py
+++ b/atdb/taskdatabase/services/activities_handler.py
@@ -186,7 +186,7 @@ def update_processed_and_aggregate(task):
     if (task.workflow.aggregation_strategy == AggregationStrategy.COLLECT_H5.value):
 
         # check if the activity is ready to collect H5 data
-        if (not activity.is_aggregated and activity.status != 'aggregate'):
+        if (not activity.is_aggregated and activity.status != State.COLLECTING_DATA.value):
 
             # check if there is already a storage_location, if not, add it.
             if activity.storage_location == "unknown":
@@ -194,7 +194,7 @@ def update_processed_and_aggregate(task):
 
             # this means that its tasks know that they should copy their H5 files to the storage_location
             # (but the tasks cannot do that, the aggregator service does)
-            activity.status = State.COLLECT_DATA.value
+            activity.status = State.COLLECTING_DATA.value
 
             activity.save()
 
diff --git a/atdb/taskdatabase/services/common.py b/atdb/taskdatabase/services/common.py
index c4da474873448c9a9399ee1c414033b602b9c1ee..0de7f32332a7afac48ab2b3e281daddb363b48ee 100644
--- a/atdb/taskdatabase/services/common.py
+++ b/atdb/taskdatabase/services/common.py
@@ -28,7 +28,7 @@ class State(Enum):
     SUSPENDED = "suspended"
     DISCARDED = "discarded"
     FAILED = "failed"
-    COLLECT_DATA = "collect_data"
+    COLLECTING_DATA = "collecting_data"
 
 VERIFIED_STATUSSES = [State.STORED.value, State.VALIDATED.value, State.SCRUBBED.value, State.PRE_ARCHIVED.value,
                       State.ARCHIVED.value, State.FINISHED.value, State.SUSPENDED.value, State.DISCARDED.value]