ce75072d by 王聪

添加fsm 任务

1 parent ea52342a
......@@ -41,7 +41,7 @@ from apps.doc.models import (
IDBCRecords,
Configs,
)
from celery_compare.tasks import compare
from celery_compare.tasks import compare, fsm_compare
class Command(BaseCommand, LoggerMixin):
......@@ -2014,6 +2014,11 @@ class Command(BaseCommand, LoggerMixin):
self.log_base, task_str, res_obj.id))
# 触发比对
try:
fsm_activited = getattr(res_obj, 'fsm_activited')
if fsm_activited:
fsm_compare.apply_async((doc.application_id, business_type, None, res_obj.id, is_ca, True),
queue='queue_compare')
else:
# pass
compare.apply_async((doc.application_id, business_type, None, res_obj.id,
is_ca, True), queue='queue_compare')
......
Styling with Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!