format w black

Author: jacalata

samples/create_extract_task.py

@@ -85,8 +85,5 @@ def main():
             print(e)
 
 
-
-
-
 if __name__ == "__main__":
     main()

samples/extracts.py

@@ -25,9 +25,9 @@ def main():
         help="desired logging level (set to error by default)",
     )
     # Options specific to this sample
-    parser.add_argument("--create",  action="store_true")
+    parser.add_argument("--create", action="store_true")
     parser.add_argument("--delete", action="store_true")
-    parser.add_argument("--refresh",  action="store_true")
+    parser.add_argument("--refresh", action="store_true")
     parser.add_argument("--workbook", required=False)
     parser.add_argument("--datasource", required=False)
     args = parser.parse_args()
@@ -43,7 +43,7 @@ def main():
     server.use_server_version()
     with server.auth.sign_in(tableau_auth):
 
-        wb = None        
+        wb = None
         ds = None
         if args.workbook:
             wb = server.workbooks.get_by_id(args.workbook)
@@ -53,7 +53,7 @@ def main():
             ds = server.datasources.get_by_id(args.datasource)
             if ds is None:
                 raise ValueError(f"Datasource not found for id {args.datasource}")
-        else:   
+        else:
             # Gets all workbook items
             all_workbooks, pagination_item = server.workbooks.get()
             print(f"\nThere are {pagination_item.total_available} workbooks on site: ")
@@ -67,20 +67,19 @@ def main():
             print("create extract on wb ", wb.name)
             extract_job = server.workbooks.create_extract(wb, includeAll=True)
             print(extract_job)
-            
+
         if args.refresh:
             extract_job = None
-            if ds is not None: 
+            if ds is not None:
                 print(f"refresh extract on datasource {ds.name}")
                 extract_job = server.datasources.refresh(ds, includeAll=True, incremental=True)
             elif wb is not None:
                 print(f"refresh extract on workbook {wb.name}")
                 extract_job = server.workbooks.refresh(wb)
-            else: 
+            else:
                 print("no content item selected to refresh")
-                
+
             print(extract_job)
-            
 
         if args.delete:
             print("delete extract on wb ", wb.name)

samples/publish_workbook.py

@@ -55,7 +55,7 @@ def main():
 
     # Step 1: Sign in to server.
     tableau_auth = TSC.PersonalAccessTokenAuth(args.token_name, args.token_value, site_id=args.site)
-    server = TSC.Server(args.server, use_server_version=True, http_options={'verify': False})
+    server = TSC.Server(args.server, use_server_version=True, http_options={"verify": False})
     with server.auth.sign_in(tableau_auth):
         # Step2: Retrieve the project id, if a project name was passed
         if args.project is not None:

samples/refresh.py

@@ -42,9 +42,8 @@ def main():
         refresh_type = "Incremental"
         incremental = True
 
-
     tableau_auth = TSC.PersonalAccessTokenAuth(args.token_name, args.token_value, site_id=args.site)
-    server = TSC.Server(args.server, use_server_version=True, http_options={'verify': False})
+    server = TSC.Server(args.server, use_server_version=True, http_options={"verify": False})
     with server.auth.sign_in(tableau_auth):
         if args.resource_type == "workbook":
             # Get the workbook by its Id to make sure it exists
@@ -61,7 +60,7 @@ def main():
             # server.datasources.create_extract(resource)
 
             # trigger the refresh, you'll get a job id back which can be used to poll for when the refresh is done
-            job = server.datasources.refresh(resource, incremental=incremental) # by default runs as a sync task, 
+            job = server.datasources.refresh(resource, incremental=incremental)  # by default runs as a sync task,
 
             print(f"{refresh_type} job posted (ID: {job.id})")
         if args.synchronous:

tableauserverclient/server/endpoint/datasources_endpoint.py

@@ -187,7 +187,7 @@ def update_connection(
         return connection
 
     @api(version="2.8")
-    def refresh(self, datasource_item: DatasourceItem, incremental: bool=False) -> JobItem:
+    def refresh(self, datasource_item: DatasourceItem, incremental: bool = False) -> JobItem:
         id_ = getattr(datasource_item, "id", datasource_item)
         url = f"{self.baseurl}/{id_}/refresh"
         refresh_req = RequestFactory.Task.refresh_req(incremental)

tableauserverclient/server/request_factory.py

@@ -1119,9 +1119,9 @@ def run_req(self, xml_request: ET.Element, task_item: Any) -> None:
 
     @_tsrequest_wrapped
     def refresh_req(self, xml_request: ET.Element, incremental: bool = False) -> bytes:
-        task_element = ET.SubElement(xml_request, 'extractRefresh')
+        task_element = ET.SubElement(xml_request, "extractRefresh")
         if incremental:
-            task_element.attrib['incremental'] = "true"
+            task_element.attrib["incremental"] = "true"
         return ET.tostring(xml_request)
 
     @_tsrequest_wrapped