fix: 修复常量定义规范问题 --story=129476203

# Reviewed, transaction id: 71505

Author: guohelu

bkflow/apigw/views/operate_task.py

@@ -26,7 +26,7 @@
 
 from bkflow.apigw.decorators import check_jwt_and_space, return_json_response
 from bkflow.apigw.serializers.task import OperateTaskSerializer
-from bkflow.constants import OPERATE_EVENT, WebhookScopeType
+from bkflow.constants import OPERATE_EVENT_MAP, WebhookScopeType
 from bkflow.contrib.api.collections.task import TaskComponentClient
 from bkflow.utils.trace import CallFrom, append_attributes, start_trace
 
@@ -48,9 +48,9 @@ def operate_task(request, space_id, task_id, operation):
         client = TaskComponentClient(space_id=space_id)
         result = client.operate_task(task_id, operation, data=ser.data)
 
-        if operation in OPERATE_EVENT:
+        if operation in ["pause", "resume", "revoke"]:
             event_broadcast_signal.send(
-                sender=OPERATE_EVENT[operation],
+                sender=OPERATE_EVENT_MAP[operation],
                 scopes=[(WebhookScopeType.SPACE.value, str(space_id))],
                 extra_info={"task_id": task_id, "operation": operation, "username": request.user.username},
             )

bkflow/constants.py

@@ -32,8 +32,6 @@
 
 formatted_key_pattern = re.compile(r"^\${(.*?)}$")
 
-OPERATE_EVENT = {"pause": "task_paused", "resume": "task_resumed", "revoke": "task_revoked"}
-
 
 class PipelineContextObjType(Enum):
     instance = "instance"
@@ -132,6 +130,13 @@ class WebhookEventType(Enum):
     TASK_REVOKED = "task_revoked"
 
 
+OPERATE_EVENT_MAP = {
+    "pause": WebhookEventType.TASK_PAUSED.value,
+    "resume": WebhookEventType.TASK_RESUMED.value,
+    "revoke": WebhookEventType.TASK_REVOKED.value,
+}
+
+
 class TriggerConstantsMode(Enum):
     """触发器参数视图类型"""
 

bkflow/task/views.py

@@ -29,7 +29,7 @@
 from rest_framework.response import Response
 
 from bkflow.constants import (
-    OPERATE_EVENT,
+    OPERATE_EVENT_MAP,
     RecordType,
     TaskOperationSource,
     TaskOperationType,
@@ -204,12 +204,12 @@ def operate(self, request, operation, *args, **kwargs):
             operator = data.pop("operator", request.user.username)
             operation_result = operation_method(operator=operator, **data)
 
-            if operation in OPERATE_EVENT:
+            if operation in ["pause", "resume", "revoke"]:
                 interface_client = InterfaceModuleClient()
                 interface_client.broadcast_task_events(
                     data={
                         "space_id": task_instance.space_id,
-                        "event": OPERATE_EVENT[operation],
+                        "event": OPERATE_EVENT_MAP[operation],
                         "extra_info": {"task_id": task_instance.id},
                     }
                 )