Signed-off-by: zhanluxianshen <zhanluxianshen@163.com>tags/1.8.0
| """ | """ | ||||
| workflow = app.workflow | workflow = app.workflow | ||||
| if not workflow: | if not workflow: | ||||
| raise ValueError("") | |||||
| raise ValueError("unexpected app type") | |||||
| return WorkflowAppGenerator().generate( | return WorkflowAppGenerator().generate( | ||||
| app_model=app, | app_model=app, |
| fi | fi | ||||
| exec celery -A app.celery worker -P ${CELERY_WORKER_CLASS:-gevent} $CONCURRENCY_OPTION \ | exec celery -A app.celery worker -P ${CELERY_WORKER_CLASS:-gevent} $CONCURRENCY_OPTION \ | ||||
| --max-tasks-per-child ${MAX_TASK_PRE_CHILD:-50} --loglevel ${LOG_LEVEL:-INFO} \ | |||||
| --max-tasks-per-child ${MAX_TASKS_PER_CHILD:-50} --loglevel ${LOG_LEVEL:-INFO} \ | |||||
| -Q ${CELERY_QUEUES:-dataset,mail,ops_trace,app_deletion,plugin,workflow_storage,conversation} | -Q ${CELERY_QUEUES:-dataset,mail,ops_trace,app_deletion,plugin,workflow_storage,conversation} | ||||
| elif [[ "${MODE}" == "beat" ]]; then | elif [[ "${MODE}" == "beat" ]]; then |
| "notion_info": fields.List(fields.Nested(integrate_workspace_fields)), | "notion_info": fields.List(fields.Nested(integrate_workspace_fields)), | ||||
| } | } | ||||
| integrate_icon_fields = {"type": fields.String, "url": fields.String, "emoji": fields.String} | |||||
| integrate_page_fields = { | integrate_page_fields = { | ||||
| "page_name": fields.String, | "page_name": fields.String, | ||||
| "page_id": fields.String, | "page_id": fields.String, |