From 5ef31b859b011e81e2e979f8309d3f6ecdbeee8c Mon Sep 17 00:00:00 2001 From: charlesxie Date: Fri, 28 Jan 2022 18:00:41 +0800 Subject: [PATCH] 2 --- .../19ee76cb-3424-4654-855f-f68454aff13a.xml | 1413 +++++++++-------- .../flow/__pycache__/models.cpython-36.pyc | Bin 2476 -> 3307 bytes .../flow/__pycache__/views.cpython-36.pyc | Bin 3415 -> 3396 bytes applications/flow/migrations/0001_initial.py | 43 +- .../migrations/0002_auto_20220128_1556.py | 18 - .../__pycache__/0001_initial.cpython-36.pyc | Bin 2580 -> 3419 bytes .../0002_auto_20220128_1556.cpython-36.pyc | Bin 620 -> 0 bytes applications/flow/models.py | 25 +- applications/flow/serializers.py | 51 +- applications/flow/urls.py | 1 + applications/flow/views.py | 21 +- .../__pycache__/plugins.cpython-36.pyc | Bin 999 -> 1044 bytes .../components/collections/plugins.py | 3 +- web/src/api/apiUrl/monitor/process_run.js | 12 +- 14 files changed, 930 insertions(+), 657 deletions(-) delete mode 100644 applications/flow/migrations/0002_auto_20220128_1556.py delete mode 100644 applications/flow/migrations/__pycache__/0002_auto_20220128_1556.cpython-36.pyc diff --git a/.idea/dataSources/19ee76cb-3424-4654-855f-f68454aff13a.xml b/.idea/dataSources/19ee76cb-3424-4654-855f-f68454aff13a.xml index 6afb4ef..e4a27fe 100644 --- a/.idea/dataSources/19ee76cb-3424-4654-855f-f68454aff13a.xml +++ b/.idea/dataSources/19ee76cb-3424-4654-855f-f68454aff13a.xml @@ -1067,2900 +1067,3069 @@ APPLICATION_PASSWORD_ADMIN,AUDIT_ADMIN,BACKUP_ADMIN,BINLOG_ADMIN,BINLOG_ENCRYPTI
-
-
-
-
-
-
-
-
-
-
-
-
-
- +
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 1 int|0s 1 null - + 2 varchar(150)|0s 1 - + name 1 btree - + 1 id 1 - + name name - + 1 bigint|0s 1 null - + 2 int|0s 1 - + 3 int|0s 1 - + group_id permission_id 1 btree - + permission_id btree - + 1 id 1 - + group_id permission_id auth_group_permissions_group_id_permission_id_0cd325b0_uniq - + group_id auth_group id - + permission_id auth_permission id - + 1 int|0s 1 null - + 2 varchar(255)|0s 1 - + 3 int|0s 1 - + 4 varchar(100)|0s 1 - + content_type_id codename 1 btree - + 1 id 1 - + content_type_id codename auth_permission_content_type_id_codename_01ab375a_uniq - + content_type_id django_content_type id - + 1 int|0s 1 null - + 2 varchar(128)|0s 1 - + 3 datetime(6)|0s - + 4 tinyint(1)|0s 1 - + 5 varchar(150)|0s 1 - + 6 varchar(150)|0s 1 - + 7 varchar(150)|0s 1 - + 8 varchar(254)|0s 1 - + 9 tinyint(1)|0s 1 - + 10 tinyint(1)|0s 1 - + 11 datetime(6)|0s 1 - + username 1 btree - + 1 id 1 - + username username - + 1 bigint|0s 1 null - + 2 int|0s 1 - + 3 int|0s 1 - + user_id group_id 1 btree - + group_id btree - + 1 id 1 - + user_id group_id auth_user_groups_user_id_group_id_94350c0c_uniq - + user_id auth_user id - + group_id auth_group id - + 1 bigint|0s 1 null - + 2 int|0s 1 - + 3 int|0s 1 - + user_id permission_id 1 btree - + permission_id btree - + 1 id 1 - + user_id permission_id auth_user_user_permissions_user_id_permission_id_14a6b632_uniq - + user_id auth_user id - + permission_id auth_permission id - + 1 int|0s 1 null - + 2 varchar(255)|0s 1 - + 3 varchar(255)|0s 1 - + 4 tinyint(1)|0s 1 - + 5 varchar(64)|0s 1 - + code version 1 btree - + code btree - + version btree - + 1 id 1 - + code version component_framework_componentmodel_code_version_1b8e366c_uniq - + 1 int|0s 1 null - + 2 datetime(6)|0s 1 - + 3 longtext|0s - + 4 varchar(200)|0s 1 - + 5 smallint unsigned|0s 1 - + 6 longtext|0s 1 - + 7 int|0s - + 8 int|0s 1 - + content_type_id btree - + user_id btree - + 1 id 1 - + content_type_id django_content_type id - + user_id auth_user id - + 1 int|0s 1 null - + 2 datetime(6)|0s 1 - + 1 id 1 - + 1 int|0s 1 null - + 2 varchar(240)|0s 1 - + 3 varchar(96)|0s 1 - + 4 varchar(64)|0s 1 - + 5 varchar(124)|0s 1 - + 6 varchar(64)|0s 1 - + 7 varchar(63)|0s 1 - + 1 id 1 - + 1 int|0s 1 null - + 2 int|0s 1 - + 3 varchar(24)|0s 1 - + 1 id 1 - + 1 int|0s 1 null - + 2 varchar(200)|0s 1 - + 3 varchar(200)|0s 1 - + 4 longtext|0s 1 - + 5 longtext|0s 1 - + 6 varchar(200)|0s - + 7 varchar(200)|0s - + 8 varchar(200)|0s - + 9 datetime(6)|0s - + 10 tinyint(1)|0s 1 - + 11 datetime(6)|0s - + 12 int unsigned|0s 1 - + 13 datetime(6)|0s 1 - + 14 longtext|0s 1 - + 15 int|0s - + 16 int|0s - + 17 int|0s - + 18 tinyint(1)|0s 1 - + 19 datetime(6)|0s - + 20 int unsigned|0s - + 21 longtext|0s 1 - + 22 int|0s - + 23 int unsigned|0s - + name 1 btree - + crontab_id btree - + interval_id btree - + solar_id btree - + clocked_id btree - + 1 id 1 - + name name - + crontab_id django_celery_beat_crontabschedule id - + interval_id django_celery_beat_intervalschedule id - + solar_id django_celery_beat_solarschedule id - + clocked_id django_celery_beat_clockedschedule id - + 1 smallint|0s 1 - + 2 datetime(6)|0s 1 - + 1 ident 1 - + 1 int|0s 1 null - + 2 varchar(24)|0s 1 - + 3 decimal(9,6 digit)|0s 1 - + 4 decimal(9,6 digit)|0s 1 - + event latitude longitude 1 btree - + 1 id 1 - + event latitude longitude django_celery_beat_solar_event_latitude_longitude_ba64999a_uniq - + 1 int|0s 1 null - + 2 varchar(255)|0s 1 - + 3 varchar(50)|0s 1 - + 4 varchar(128)|0s 1 - + 5 varchar(64)|0s 1 - + 6 longtext|0s - + 7 datetime(6)|0s 1 - + 8 longtext|0s - + 9 longtext|0s - + 10 longtext|0s - + 11 longtext|0s - + 12 varchar(255)|0s - + 13 varchar(100)|0s - + 14 datetime(6)|0s 1 - + task_id 1 btree - + status btree - + date_done btree - + task_name btree - + worker btree - + date_created btree - + 1 id 1 - + task_id task_id - + 1 int|0s 1 null - + 2 varchar(100)|0s 1 - + 3 varchar(100)|0s 1 - + app_label model 1 btree - + 1 id 1 - + app_label model django_content_type_app_label_model_76bd3d3b_uniq - + 1 bigint|0s 1 null - + 2 varchar(255)|0s 1 - + 3 varchar(255)|0s 1 - + 4 datetime(6)|0s 1 - + 1 id 1 - + 1 varchar(40)|0s 1 - + 2 longtext|0s 1 - + 3 datetime(6)|0s 1 - + expire_date btree - + 1 session_key 1 - + 1 varchar(32)|0s 1 - + 2 longblob|0s 1 - + 3 longblob|0s 1 - + 4 longblob|0s 1 - + 1 id 1 - + 1 varchar(255)|0s 1 - + 2 longblob|0s 1 - + 1 key 1 - + 1 int|0s 1 null - + 2 varchar(32)|0s 1 - + 3 longtext|0s 1 - + 4 tinyint(1)|0s 1 - + name 1 btree - + 1 id 1 - + name engine_functionswitch_name_4eaabfd5_uniq - + 1 bigint|0s 1 null - + 2 varchar(32)|0s 1 - + 3 datetime(6)|0s 1 - + 4 datetime(6)|0s 1 - + 5 bigint|0s - + 6 int|0s 1 - + 7 tinyint(1)|0s 1 - + identifier btree - + data_id btree - + 1 id 1 - + data_id engine_historydata id - + 1 bigint|0s 1 null - + 2 longblob|0s 1 - + 3 longblob|0s 1 - + 4 longblob|0s 1 - + 1 id 1 - + 1 bigint|0s 1 null - + 2 varchar(64)|0s 1 - + 3 longblob|0s 1 - + 1 id 1 - + 1 bigint|0s 1 null - + 2 varchar(32)|0s 1 - + 3 varchar(40)|0s 1 - + node_id 1 btree - + 1 id 1 - + node_id node_id - + 1 bigint|0s 1 null - + 2 varchar(32)|0s 1 - + 3 varchar(32)|0s 1 - + 4 int|0s 1 - + ancestor_id btree - + descendant_id btree - + distance btree - + 1 id 1 - + 1 varchar(32)|0s 1 - + 2 varchar(32)|0s - + 3 int|0s 1 - + 4 varchar(512)|0s 1 - + process_id btree - + 1 id 1 - + process_id engine_pipelineprocess id - + 1 varchar(32)|0s 1 - + 2 varchar(32)|0s 1 - + 3 varchar(32)|0s 1 - + 4 varchar(32)|0s 1 - + 5 varchar(32)|0s 1 - + 6 int|0s 1 - + 7 int|0s 1 - + 8 tinyint(1)|0s 1 - + 9 tinyint(1)|0s 1 - + 10 bigint|0s - + 11 tinyint(1)|0s 1 - + root_pipeline_id btree - + current_node_id btree - + parent_id btree - + is_alive btree - + is_sleep btree - + snapshot_id btree - + is_frozen btree - + 1 id 1 - + snapshot_id engine_processsnapshot id - + 1 bigint|0s 1 null - + 2 varchar(32)|0s 1 - + 3 varchar(40)|0s 1 - + process_id 1 btree - + 1 id 1 - + process_id process_id - + 1 bigint|0s 1 null - + 2 longblob|0s 1 - + 1 id 1 - + 1 bigint|0s 1 null - + 2 varchar(64)|0s 1 - + 3 varchar(40)|0s 1 - + schedule_id 1 btree - + 1 id 1 - + schedule_id schedule_id - + 1 varchar(64)|0s 1 - + 2 varchar(32)|0s 1 - + 3 varchar(32)|0s 1 - + 4 int|0s 1 - + 5 tinyint(1)|0s 1 - + 6 longblob|0s 1 - + 7 longblob|0s 1 - + 8 tinyint(1)|0s 1 - + 9 varchar(32)|0s 1 - + 10 tinyint(1)|0s 1 - + 11 tinyint(1)|0s 1 - + activity_id btree - + version btree - + is_scheduling btree - + 1 id 1 - + 1 bigint|0s 1 null - + 2 varchar(1024)|0s 1 - + 3 longtext|0s 1 - + 4 int|0s 1 - + 5 longtext|0s 1 - + 6 longtext|0s 1 - + 7 datetime(6)|0s 1 - + 1 id 1 - + 1 varchar(32)|0s 1 - + 2 varchar(10)|0s 1 - + 3 varchar(64)|0s 1 - + 4 int|0s 1 - + 5 int|0s 1 - + 6 tinyint(1)|0s 1 - + 7 datetime(6)|0s 1 - + 8 datetime(6)|0s - + 9 datetime(6)|0s - + 10 varchar(32)|0s 1 - + 11 tinyint(1)|0s 1 - + 12 datetime(6)|0s - + created_time btree - + 1 id 1 - + 1 bigint|0s 1 null - + 2 varchar(32)|0s 1 - + 3 varchar(32)|0s 1 - + subprocess_id btree - + 1 id 1 - + 1 bigint|0s 1 null - + 2 varchar(33)|0s 1 - + 3 varchar(33)|0s 1 - + 4 longtext|0s 1 - + 1 id 1 - + 1 bigint|0s 1 null - + 2 varchar(33)|0s 1 - + 3 longtext|0s 1 - + pipeline_id 1 btree - + 1 id 1 - + pipeline_id pipeline_id - + 1 bigint|0s 1 null - + 2 varchar(33)|0s 1 - + 3 varchar(128)|0s 1 - + 4 int|0s 1 - + 5 varchar(32)|0s 1 - + 6 varchar(128)|0s 1 - + 7 longtext|0s 1 - + 8 longtext|0s 1 - + pipeline_id key 1 btree - + 1 id 1 - + pipeline_id key eri_contextvalue_pipeline_id_key_df86ad76_uniq - + 1 bigint|0s 1 null - + 2 varchar(33)|0s 1 - + 3 longtext|0s 1 - + 4 longtext|0s 1 - + node_id 1 btree - + 1 id 1 - + node_id node_id - + 1 bigint|0s 1 null - + 2 varchar(33)|0s 1 - + 3 varchar(32)|0s 1 - + 4 varchar(32)|0s 1 - + 5 longtext|0s 1 - + 6 longtext|0s 1 - + node_id 1 btree - + 1 id 1 - + node_id node_id - + 1 bigint|0s 1 null - + 2 varchar(33)|0s 1 - + 3 int|0s 1 - + 4 int|0s 1 - + 5 tinyint(1)|0s 1 - + 6 varchar(33)|0s 1 - + 7 datetime(6)|0s 1 - + 8 datetime(6)|0s 1 - + 9 varchar(32)|0s 1 - + 10 varchar(32)|0s 1 - + 11 longtext|0s 1 - + 12 longtext|0s 1 - + node_id loop btree - + 1 id 1 - + 1 bigint|0s 1 null - + 2 varchar(33)|0s 1 - + 3 int|0s 1 - + 4 varchar(128)|0s 1 - + 5 varchar(32)|0s 1 - + 6 longtext|0s - + 7 datetime(6)|0s 1 - + 8 varchar(33)|0s 1 - + node_id loop btree - + logged_at btree - + 1 id 1 - + 1 bigint|0s 1 null - + 2 varchar(33)|0s 1 - + 3 longtext|0s 1 - + node_id btree - + 1 id 1 - + 1 bigint|0s 1 null - + 2 bigint|0s 1 - + 3 int|0s 1 - + 4 int|0s 1 - + 5 tinyint(1)|0s 1 - + 6 tinyint(1)|0s 1 - + 7 tinyint(1)|0s 1 - + 8 tinyint(1)|0s 1 - + 9 datetime(6)|0s 1 - + 10 varchar(33)|0s 1 - + 11 varchar(33)|0s 1 - + 12 varchar(33)|0s 1 - + 13 varchar(33)|0s 1 - + 14 int|0s 1 - + 15 varchar(128)|0s 1 - + 16 longtext|0s 1 - + parent_id btree - + last_heartbeat btree - + current_node_id btree - + root_pipeline_id btree - + suspended_by btree - + 1 id 1 - + 1 bigint|0s 1 null - + 2 int|0s 1 - + 3 bigint|0s 1 - + 4 varchar(33)|0s 1 - + 5 tinyint(1)|0s 1 - + 6 tinyint(1)|0s 1 - + 7 tinyint(1)|0s 1 - + 8 varchar(33)|0s 1 - + 9 int|0s 1 - + node_id version 1 btree - + 1 id 1 - + node_id version eri_schedule_node_id_version_41a8c75a_uniq - + 1 bigint|0s 1 null - + 2 varchar(33)|0s 1 - + 3 varchar(33)|0s 1 - + 4 varchar(33)|0s 1 - + 5 varchar(64)|0s 1 - + 6 varchar(33)|0s 1 - + 7 int|0s 1 - + 8 int|0s 1 - + 9 tinyint(1)|0s 1 - + 10 tinyint(1)|0s 1 - + 11 datetime(6)|0s 1 - + 12 datetime(6)|0s - + 13 datetime(6)|0s - + 14 int|0s 1 - + node_id 1 btree - + root_id btree - + parent_id btree - + 1 id 1 - + node_id node_id - + 1 int|0s 1 null - + 2 varchar(255)|0s 1 - + 1 id 1 - + 1 int|0s 1 null - + 2 varchar(255)|0s 1 - + 3 varchar(255)|0s 1 - + 4 varchar(255)|0s - + 5 - int|0s + tinyint(1)|0s 1 - + 6 int|0s 1 - + 7 + int|0s + 1 + + + 8 + varchar(64)|0s + + + 9 + int|0s + 1 + + + 10 + int|0s + 1 + + + 11 varchar(32)|0s 1 - - 8 + + 12 int|0s 1 - - 9 + + 13 varchar(255)|0s 1 - - 10 - tinyint(1)|0s - 1 - - - 11 - tinyint(1)|0s - 1 - - - 12 - json|0s - 1 - - - 13 - json|0s - 1 - - + 14 + tinyint(1)|0s + 1 + + + 15 + tinyint(1)|0s + 1 + + + 16 + json|0s + 1 + + + 17 + json|0s + 1 + + + 18 int|0s - + + uuid + 1 + btree + + process_id btree - + 1 id 1 - + + uuid + uuid + + 1 int|0s 1 null - + 2 varchar(255)|0s 1 - + + 3 + varchar(255)|0s + 1 + + + 4 + varchar(255)|0s + + + 5 + tinyint(1)|0s + 1 + + + 6 + int|0s + 1 + + + 7 + int|0s + 1 + + + 8 + varchar(64)|0s + + + 9 + int|0s + 1 + + + 10 + int|0s + 1 + + + 11 + varchar(32)|0s + 1 + + + 12 + int|0s + 1 + + + 13 + varchar(255)|0s + 1 + + + 14 + tinyint(1)|0s + 1 + + + 15 + tinyint(1)|0s + 1 + + + 16 + json|0s + 1 + + + 17 + json|0s + 1 + + + 18 + int|0s + + + uuid + 1 + btree + + + process_run_id + btree + + + 1 + id + 1 + + + uuid + uuid + + + 1 + int|0s + 1 + null + + + 2 + varchar(255)|0s + 1 + + 3 varchar(255)|0s - + 4 varchar(32)|0s 1 - + 5 int unsigned|0s 1 - + 6 json|0s 1 - + 7 json|0s 1 - + 8 json|0s 1 - + 9 varchar(64)|0s - + 10 datetime(6)|0s 1 - + 11 datetime(6)|0s 1 - + 12 varchar(64)|0s - + 1 id 1 - + 1 int|0s 1 null - + 2 int|0s 1 - + 3 int|0s 1 - + process_id category_id 1 btree - + category_id btree - + 1 id 1 - + process_id category_id flow_process_category_process_id_category_id_e1ab1b26_uniq - + process_id flow_process id - + category_id flow_category id - + + 1 + int|0s + 1 + + + 2 + varchar(32)|0s + 1 + + + 3 + varchar(255)|0s + 1 + + + 4 + int|0s + + + process_id + btree + + + 1 + process_ptr_id + 1 + + + process_ptr_id + flow_process + id + + 1 bigint|0s 1 null - + 2 varchar(128)|0s 1 - + 3 varchar(32)|0s 1 - + 4 longtext|0s - + 5 longtext|0s - + 6 datetime(6)|0s 1 - + 7 varchar(32)|0s 1 - + 8 int|0s 1 - + logger_name btree - + level_name btree - + logged_at btree - + node_id btree - + 1 id 1 - + 1 int|0s 1 null - + 2 varchar(32)|0s 1 - + 3 varchar(128)|0s 1 - + 4 varchar(32)|0s 1 - + 5 datetime(6)|0s 1 - + 6 varchar(32)|0s 1 - + 7 datetime(6)|0s - + 8 datetime(6)|0s - + 9 longtext|0s 1 - + 10 tinyint(1)|0s 1 - + 11 tinyint(1)|0s 1 - + 12 tinyint(1)|0s 1 - + 13 int|0s - + 14 int|0s - + 15 int|0s - + 16 int|0s - + 17 tinyint(1)|0s 1 - + 18 tinyint(1)|0s 1 - + instance_id 1 btree - + create_time btree - + execution_snapshot_id btree - + snapshot_id btree - + template_id btree - + tree_info_id btree - + 1 id 1 - + instance_id instance_id - + execution_snapshot_id pipeline_snapshot id - + snapshot_id pipeline_snapshot id - + template_id pipeline_pipelinetemplate id - + tree_info_id pipeline_treeinfo id - + 1 int|0s 1 null - + 2 varchar(32)|0s 1 - + 3 varchar(128)|0s 1 - + 4 datetime(6)|0s 1 - + 5 varchar(32)|0s 1 - + 6 longtext|0s - + 7 varchar(32)|0s - + 8 datetime(6)|0s 1 - + 9 tinyint(1)|0s 1 - + 10 int|0s 1 - + 11 tinyint(1)|0s 1 - + template_id 1 btree - + name btree - + create_time btree - + edit_time btree - + snapshot_id btree - + 1 id 1 - + template_id template_id - + snapshot_id pipeline_snapshot id - + 1 int|0s 1 null - + 2 longtext|0s 1 - + 3 varchar(64)|0s 1 - + 4 longblob|0s 1 - + 1 id 1 - + 1 int|0s 1 null - + 2 varchar(32)|0s 1 - + 3 datetime(6)|0s 1 - + 4 longblob|0s - + md5sum btree - + 1 id 1 - + 1 int|0s 1 null - + 2 varchar(32)|0s 1 - + 3 varchar(32)|0s 1 - + template_id btree - + 1 id 1 - + 1 int|0s 1 null - + 2 varchar(32)|0s 1 - + 3 varchar(32)|0s 1 - + 4 varchar(32)|0s 1 - + 5 varchar(32)|0s 1 - + 6 tinyint(1)|0s 1 - + ancestor_template_id btree - + descendant_template_id btree - + 1 id 1 - + 1 int|0s 1 null - + 2 varchar(97)|0s 1 - + 3 varchar(64)|0s 1 - + 4 datetime(6)|0s 1 - + 5 longblob|0s 1 - + 6 int|0s 1 - + unique_id 1 btree - + template_id btree - + 1 id 1 - + unique_id unique_id - + template_id pipeline_pipelinetemplate id - + 1 int|0s 1 null - + 2 int|0s 1 - + 3 int|0s 1 - + templatescheme_id templaterelationship_id 1 btree - + templaterelationship_id btree - + 1 id 1 - + templatescheme_id templaterelationship_id pipeline_templatescheme__templatescheme_id_templa_dff0f4f6_uniq - + templatescheme_id pipeline_templatescheme id - + templaterelationship_id pipeline_templaterelationship id - + 1 int|0s 1 null - + 2 varchar(32)|0s 1 - + 3 datetime(6)|0s 1 - + 4 int|0s 1 - + 5 int|0s 1 - + md5 btree - + snapshot_id btree - + template_id btree - + 1 id 1 - + snapshot_id pipeline_snapshot id - + template_id pipeline_pipelinetemplate id - + 1 int|0s 1 null - + 2 longblob|0s - + 1 id 1 diff --git a/applications/flow/__pycache__/models.cpython-36.pyc b/applications/flow/__pycache__/models.cpython-36.pyc index 8ffb0ff58e5bcafe96641da7c4fa1912bcb64738..96cb5a19f7a73286badb81c9cd67be120fb23662 100644 GIT binary patch delta 1107 zcmZ`%y=xRf6yLAgox9z;+xy7JCDDWgG~1+z8jau)L?ad+qDiw&I5S(sA}6!AjTUDT zZ2|{|1uGF76+tl~Dk%j237c)zL=Z)=R{XuWm_&)Y%x~WBy?Jlm$2={4sf--SW;5S5 ze$?+eit<6(^BIt*u);@cBhkb;g*!ZZOX1nTS<(G0c#h}6^MMVX19y1=yddp)Uc9V$ zr5E>a8*9JPnxV#Nb)XgKR}G%x8aKJs)_qfQCb`Ltw&7dQFrJ1z)7JbnSccn>Ro~tt zJJJv7;9SQqE3HUK`sE~Zw^?4EE(9)b6?qBQ7Nof>!xp8n3n}RMDTNX=jCX@k3T4T9 zwpmxu&3l6$Y3YSr*_JD)zK{2#`u-Ko@8big{XoJ_*TbOJ;6a4eDxX)E4{t4Re7e)# zdb}77?Ckk7GcTW*s@j@|V&_vKO<{#DAW(djE5626U*{U`(ywR# z+%~$wHbs5DDGH?9g(6uEaytqs)BsEsqbBy6*B^h?2jlP7 zJ7W|)e$EaW!z8?CLxYYcNd7BN3yLYMa9D}QQbQ(BAw4s$npM5#vG|!a8LzYQ*f@@y zpkwsNn3_`sY4(p)rAS`O+I|p>(*q%v;TZ(ClgvfYm=D76QnWZTo#-N3MDe^W69+yJ6FKg!Hb) Z&GeyOYMY}uDt^t;i$>8c_PHsS{RZYb<01e6 delta 404 zcmYk2u}i~16vlH&hy1X;YC_khnT2A{|^r=ptRR2`?Z{64AxM$uShU%|+Z@ zivNX!IJ-JJ`VaVgR%k+w?|0w#a_`<(_8gCQw3ZJ~->3W1vOcYq$3;EC@ACS7eC2^U zu?oF-yK~J%3R^LAEQ?zkY*=gDQdG`42M!)E5RFqxVoA&>;p2`1AAQx>rA7)sqh@7m zMTb-uKnrt!b!~D(Xj5H86fG$}qj+3(paWezwo7(GzfH(Xv4#I8Q`}L|L;h`{N0coo ztNPHd2IS}9OwEfJ{UPT^{1s^M*BtmQ7u z3uh=11ghaH5y}#-;i}#(k)X6JZT_%5F&1KY`oWy3Wtj55=P^1bX#NdQD zh$R9f6o9x`WAXtuaeh8V4n`nm;$jqHVq@f+{DLisQGK&F`*KDOMW8B8#v-N3zc^+x zdQP6gsimm`5@Ldw3${TPA#jVmC_ld>J~KsArbut{bIue-<;gx=R>HSf3yL!HN{U#4 zN{g64gxTcjT&Ch6vx-hzaq+WNB`FMw`vv+}uozngApZ BU~>Qf delta 417 zcmYk0J4*vW6ouzbvhVC><0~d;<0HC3O%Y6jqTr(v!NS5u@xh2BVxq$|!YnCP8zCS} zqm81CSXfB#AK2N57D74;e}Q1_jtE+u!{NJ!!+lJ@rH#C8o9yay^WomOjKG(;jga~( zH;78mF;1a*w6^HSxW;2CM6^))E~Y0e79iiQ_Wk2($gi3G!%gN8gP0BQZ5HPiu>#EP z0DSA9x`LP+b{v+dv~iO=B-X%woVD|K0DxFWcyqg1XQhj~JWlKe4q>v40$4_#BhI3E zt7TMcWP6<*?r)2y=mrdm5oJeQD05m%*{9_y6Yt6%jEN<6QXN7F(Tq4%dmt(rB&5*2~1} zp*itl5Eu|eb0R?tvaLwN(u(5998bz68V${JX-Vd3X*1&49JOX;{QXt8axm2_Sr&%u EH$PxuVE_OC diff --git a/applications/flow/migrations/0001_initial.py b/applications/flow/migrations/0001_initial.py index 5b90741..f1628c9 100644 --- a/applications/flow/migrations/0001_initial.py +++ b/applications/flow/migrations/0001_initial.py @@ -1,4 +1,4 @@ -# Generated by Django 2.2.6 on 2022-01-28 07:05 +# Generated by Django 2.2.6 on 2022-01-28 09:40 import datetime from django.db import migrations, models @@ -44,7 +44,7 @@ class Migration(migrations.Migration): fields=[ ('id', models.AutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')), ('name', models.CharField(max_length=255, verbose_name='节点名称')), - ('uuid', models.CharField(max_length=255, verbose_name='UUID')), + ('uuid', models.CharField(max_length=255, unique=True, verbose_name='UUID')), ('description', models.CharField(blank=True, max_length=255, null=True, verbose_name='节点描述')), ('show', models.BooleanField(default=True, verbose_name='是否显示')), ('top', models.IntegerField(default=300)), @@ -61,5 +61,44 @@ class Migration(migrations.Migration): ('outputs', django_mysql.models.JSONField(default=dict, verbose_name='输出参数')), ('process', models.ForeignKey(db_constraint=False, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='nodes', to='flow.Process')), ], + options={ + 'abstract': False, + }, + ), + migrations.CreateModel( + name='ProcessRun', + fields=[ + ('process_ptr', models.OneToOneField(auto_created=True, on_delete=django.db.models.deletion.CASCADE, parent_link=True, primary_key=True, serialize=False, to='flow.Process')), + ('state', models.CharField(max_length=32, verbose_name='工作流状态')), + ('root_id', models.CharField(max_length=255, verbose_name='根节点uuid')), + ('process', models.ForeignKey(db_constraint=False, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='run', to='flow.Process')), + ], + bases=('flow.process',), + ), + migrations.CreateModel( + name='NodeRun', + fields=[ + ('id', models.AutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')), + ('name', models.CharField(max_length=255, verbose_name='节点名称')), + ('uuid', models.CharField(max_length=255, unique=True, verbose_name='UUID')), + ('description', models.CharField(blank=True, max_length=255, null=True, verbose_name='节点描述')), + ('show', models.BooleanField(default=True, verbose_name='是否显示')), + ('top', models.IntegerField(default=300)), + ('left', models.IntegerField(default=300)), + ('ico', models.CharField(blank=True, max_length=64, null=True, verbose_name='icon')), + ('fail_retry_count', models.IntegerField(default=0, verbose_name='失败重试次数')), + ('fail_offset', models.IntegerField(default=0, verbose_name='失败重试间隔')), + ('fail_offset_unit', models.CharField(choices=[('seconds', '秒'), ('hours', '时'), ('minutes', '分')], max_length=32, verbose_name='重试间隔单位')), + ('node_type', models.IntegerField(default=2)), + ('component_code', models.CharField(max_length=255, verbose_name='插件名称')), + ('is_skip_fail', models.BooleanField(default=False, verbose_name='忽略失败')), + ('is_timeout_alarm', models.BooleanField(default=False, verbose_name='超时告警')), + ('inputs', django_mysql.models.JSONField(default=dict, verbose_name='输入参数')), + ('outputs', django_mysql.models.JSONField(default=dict, verbose_name='输出参数')), + ('process_run', models.ForeignKey(db_constraint=False, null=True, on_delete=django.db.models.deletion.SET_NULL, related_name='nodes_run', to='flow.ProcessRun')), + ], + options={ + 'abstract': False, + }, ), ] diff --git a/applications/flow/migrations/0002_auto_20220128_1556.py b/applications/flow/migrations/0002_auto_20220128_1556.py deleted file mode 100644 index 06d6c1c..0000000 --- a/applications/flow/migrations/0002_auto_20220128_1556.py +++ /dev/null @@ -1,18 +0,0 @@ -# Generated by Django 2.2.6 on 2022-01-28 07:56 - -from django.db import migrations, models - - -class Migration(migrations.Migration): - - dependencies = [ - ('flow', '0001_initial'), - ] - - operations = [ - migrations.AlterField( - model_name='node', - name='uuid', - field=models.CharField(max_length=255, unique=True, verbose_name='UUID'), - ), - ] diff --git a/applications/flow/migrations/__pycache__/0001_initial.cpython-36.pyc b/applications/flow/migrations/__pycache__/0001_initial.cpython-36.pyc index 015bcb65ddad5dcbfce05af0c8a8203eec92d1ba..03647ee3c8476d9ad58e5c6eb8245aadde2d8f93 100644 GIT binary patch delta 1272 zcmd5)OHUI~6zt&M>54{` z{cpdiADSL34?+9D??ulo6qtgmf7M2;=I2+M*x1PUK>UyP&Zs zB2FT%gKjun6cF`Ppd&oL1@%XH{xMHc565}_364*4e5&9j&4C7bR)QGx!+=-JIZt?= z8(r{JVYmp2SH>XX82Dj`Uvr7$VU9;gL=WjzBnqRPxxB@Uab_HI;!yB|KZTvoW{|eocUDMTrFTAWXqDChXj%Zo)nVEMgL_7lZg3H}G7>7G`*nH$5DN z6vt)5O21nTTZVp^hgoixE`1aZ{vV^s!2%fncr@UR=3wPh5y<>GnrvXY8M5QPgt@j? zniAs)iB{v!?FJn~TXYDGAXvK>_$d_JusUnmR88BcsY068Fk#5d+nQ-ut};r^G_kBP z$8aP0a-7QBG!dj>rtW3xNM5DHuv0nBn5QzM6}IhTX93GrZQ`(7zr1<=`Q5XPS4*2K zuQ%>5xgly6Ogp846UEbw)%C9{%bUyVj-!DqQOEdEmC2d6+qi2*eSulkB9 zhH0*BAZw*Cyj$bl@VkfMgh<<2Z5_B_e5R9ut};lnxSPcS9V}DZwSSlHT3Zd(3kRYj z2AME%8_-A&+)!Wdcwg_?epfN`gsR?KzVK0p)kHteIN4V=d;|7O>@hn({ih= KXukAa-t!9>=UGbt delta 491 zcmcaDHARHWn3tDp@zl?W>-i^gwQ|ccFfcd(ad8XN##yP1_4+AXy-aCLDSWByS)3`1 zDI7p-kRs5_0u(a@iU|SvMk(T8HO4@`aEeKaX)hyC)(nMb4%IIYRBr**ZwXc*nqmdj zZw=+!K>4<*?DarP!&4$sBGZ{ugi>5mTzi>;M!SI(xa`juN*tg1LzEEe*{AZ z{*qUw&TK4joJ&<~`RF{qbH3xp`}^tj_g~^VAmk_c?=aMl@Qsg90D(Z0E+~U8EW?1j zB@hDrMu5s-OTW^R0{cL+=mv917P_=k?I0#)&FJFJg4AQisRgV`tiacI!OPH(VJtDWM%R*wV3i zR&etNJA8EP^z_}UjN)M83)j-L)47Xhqb_FY)}Q21+fi~OI=STdffoyr(C4BvB{iI6 z;SeF(5TnReF5ycK=PuK&_> z=VE8O)b{e<-hPnbfp6x;@A~z#s=+KR$EvZQOk35WtF7foMH$I^EiT)^&IT&c_gXc( zYQ>=t5oAd$!t<1HrdV2vm=r_R)!+rm zDhU7DyIY-JpUF_fo!*H1!;8)tOYZQIT>u(kik)PRPaAarnIh+E$+2-+TF}g*c1y{- zvAU+)=8H6JfLn$e>!uVFuq@|R64wmcQg7r{{XsO6sv9xY>kBURVp0pT(p<~zg&Ghk aZ4E|z9ExrD1QhETDX!x(Os&l^>-Im5r(CoE delta 310 zcmbQj@tj@Rn3tE!@ymxqQziz6#|%h-1;};);^L%<%H~?B>{%QsEX|BjobC)MtSM|Q z3@L1>OwG(uTtGg13I~wSk;)3>b5HD9rp*J?SHh6O*v!btkirzqpvml4$_W&E*17z} z!k#C)+CnrLZ?P5>W#*Mku4I&BpJEI