move trigger workflow apis from Base to Account

Author: AlexCXC

seatable_api/main.py

@@ -181,12 +181,6 @@ def _send_toast_notification_url(self):
             'dtable_uuid': self.dtable_uuid
         }
 
-    def _add_workflow_task_url(self, token):
-        return '%(server_url)s/api/v2.1/workflows/%(token)s/external-task-submit/' % {
-            'server_url': self.server_url,
-            'token': token
-        }
-
     def _get_account_detail(self, account_name):
         url = self._third_party_accounts_url()
         params = {
@@ -924,22 +918,6 @@ def send_toast_notification(self, user_id, msg, toast_type='success'):
             }
         }, headers=self.headers)
 
-    def add_workflow_task(self, workflow_token, row_data, link_rows=None, new_linked_rows=None):
-        url = self._add_workflow_task_url(workflow_token)
-        headers = {'Authorization': 'Token ' + self.jwt_token}
-        response = requests.post(url, data={
-            'row_data': json.dumps(row_data),
-            'link_rows': json.dumps(link_rows or []),
-            'new_linked_rows': json.dumps(new_linked_rows or [])
-        }, headers=headers)
-        return parse_response(response)['task']
-
-    def add_workflow_task_with_existed_row(self, workflow_token, row_id):
-        url = self._add_workflow_task_url(workflow_token)
-        headers = {'Authorization': 'Token ' + self.jwt_token}
-        response = requests.post(url, data={'row_id': row_id}, headers=headers)
-        return parse_response(response)['task']
-
 
 class Account(object):
     def __init__(self, login_name, password, server_url):
@@ -975,6 +953,12 @@ def _get_temp_api_token_url(self, workspace_id, name):
             'name': name
         }
 
+    def _add_workflow_task_url(self, token):
+        return '%(server_url)s/api/v2.1/workflows/%(token)s/task-submit/' % {
+            'server_url': self.server_url,
+            'token': token
+        }
+
     @property
     def token_headers(self):
         return {
@@ -1037,3 +1021,19 @@ def get_base(self, workspace_id, base_name, with_socket_io=False):
         base = SeaTableAPI(api_token, self.server_url)
         base.auth(with_socket_io=with_socket_io)
         return base
+
+    def add_workflow_task(self, workflow_token, row_data, link_rows=None, new_linked_rows=None):
+        url = self._add_workflow_task_url(workflow_token)
+        headers = {'Authorization': 'Token ' + self.token}
+        response = requests.post(url, data={
+            'row_data': json.dumps(row_data),
+            'link_rows': json.dumps(link_rows or []),
+            'new_linked_rows': json.dumps(new_linked_rows or [])
+        }, headers=headers)
+        return parse_response(response)['task']
+
+    def add_workflow_task_with_existed_row(self, workflow_token, row_id):
+        url = self._add_workflow_task_url(workflow_token)
+        headers = {'Authorization': 'Token ' + self.token}
+        response = requests.post(url, data={'row_id': row_id}, headers=headers)
+        return parse_response(response)['task']