@@ -181,6 +181,12 @@ def _send_toast_notification_url(self):
181181 'dtable_uuid' : self .dtable_uuid
182182 }
183183
184+ def _add_workflow_task_url (self , token ):
185+ return '%(server_url)s/api/v2.1/workflows/%(token)s/external-task-submit/' % {
186+ 'server_url' : self .server_url ,
187+ 'token' : token
188+ }
189+
184190 def _get_account_detail (self , account_name ):
185191 url = self ._third_party_accounts_url ()
186192 params = {
@@ -918,6 +924,22 @@ def send_toast_notification(self, user_id, msg, toast_type='success'):
918924 }
919925 }, headers = self .headers )
920926
927+ def add_workflow_task (self , workflow_token , row_data , link_rows = None , new_linked_rows = None ):
928+ url = self ._add_workflow_task_url (workflow_token )
929+ headers = {'Authorization' : 'Token ' + self .jwt_token }
930+ response = requests .post (url , data = {
931+ 'row_data' : json .dumps (row_data ),
932+ 'link_rows' : json .dumps (link_rows or []),
933+ 'new_linked_rows' : json .dumps (new_linked_rows or [])
934+ }, headers = headers )
935+ return parse_response (response )['task' ]
936+
937+ def add_workflow_task_with_existed_row (self , workflow_token , row_id ):
938+ url = self ._add_workflow_task_url (workflow_token )
939+ headers = {'Authorization' : 'Token ' + self .jwt_token }
940+ response = requests .post (url , data = {'row_id' : row_id }, headers = headers )
941+ return parse_response (response )['task' ]
942+
921943
922944class Account (object ):
923945 def __init__ (self , login_name , password , server_url ):
@@ -953,12 +975,6 @@ def _get_temp_api_token_url(self, workspace_id, name):
953975 'name' : name
954976 }
955977
956- def _add_workflow_task_url (self , token ):
957- return '%(server_url)s/api/v2.1/workflows/%(token)s/task-submit/' % {
958- 'server_url' : self .server_url ,
959- 'token' : token
960- }
961-
962978 @property
963979 def token_headers (self ):
964980 return {
@@ -1021,19 +1037,3 @@ def get_base(self, workspace_id, base_name, with_socket_io=False):
10211037 base = SeaTableAPI (api_token , self .server_url )
10221038 base .auth (with_socket_io = with_socket_io )
10231039 return base
1024-
1025- def add_workflow_task (self , workflow_token , row_data , link_rows = None , new_linked_rows = None ):
1026- url = self ._add_workflow_task_url (workflow_token )
1027- headers = {'Authorization' : 'Token ' + self .token }
1028- response = requests .post (url , data = {
1029- 'row_data' : json .dumps (row_data ),
1030- 'link_rows' : json .dumps (link_rows or []),
1031- 'new_linked_rows' : json .dumps (new_linked_rows or [])
1032- }, headers = headers )
1033- return parse_response (response )['task' ]
1034-
1035- def add_workflow_task_with_existed_row (self , workflow_token , row_id ):
1036- url = self ._add_workflow_task_url (workflow_token )
1037- headers = {'Authorization' : 'Token ' + self .token }
1038- response = requests .post (url , data = {'row_id' : row_id }, headers = headers )
1039- return parse_response (response )['task' ]
0 commit comments