|
18 | 18 | from rest_framework import serializers
|
19 | 19 |
|
20 | 20 | from common.config import SysConfig
|
21 |
| -from common.utils.const import WorkflowDict |
22 | 21 | from sql.engines import ReviewSet, get_engine
|
23 | 22 | from sql.engines.models import ReviewResult
|
24 | 23 | from sql.models import Instance, SqlWorkflow, Users
|
@@ -256,7 +255,9 @@ def mysql_osc_control(obj, sqlsha1, command):
|
256 | 255 | """用于MySQL的大表DDL控制"""
|
257 | 256 | execute_engine = get_engine(instance=obj.instance)
|
258 | 257 | try:
|
259 |
| - execute_result = execute_engine.osc_control(command=command, sqlsha1=sqlsha1) |
| 258 | + execute_result = execute_engine.osc_control( |
| 259 | + command=command, sqlsha1=sqlsha1 |
| 260 | + ) |
260 | 261 | rows = execute_result.to_dict()
|
261 | 262 | error = execute_result.error
|
262 | 263 | except Exception as e:
|
@@ -296,5 +297,6 @@ class SqlWorkflowMySQLOscControlSerializer(serializers.Serializer):
|
296 | 297 | label="SQL审核返回的sqlsha1信息",
|
297 | 298 | )
|
298 | 299 | command = serializers.ChoiceField(
|
299 |
| - choices=["get", "pause", "resume", "kill"], label="命令:get-获取详情,pause-暂停,resume-恢复,kill-终止" |
| 300 | + choices=["get", "pause", "resume", "kill"], |
| 301 | + label="命令:get-获取详情,pause-暂停,resume-恢复,kill-终止", |
300 | 302 | )
|
0 commit comments