diff --git a/cqp-core/src/main/java/com/quantori/cqp/core/task/service/TaskPersistenceService.java b/cqp-core/src/main/java/com/quantori/cqp/core/task/service/TaskPersistenceService.java
index 6d7f96f..fdd2aeb 100644
--- a/cqp-core/src/main/java/com/quantori/cqp/core/task/service/TaskPersistenceService.java
+++ b/cqp-core/src/main/java/com/quantori/cqp/core/task/service/TaskPersistenceService.java
@@ -57,5 +57,5 @@ void persistFlowState(
 
   StreamTaskDescription restoreTaskFromStatus(TaskStatus subtaskStatus);
 
-  void updateStatus(String flowId);
+  void updateStatus(String taskId);
 }