fixed bug in presentation flow and updated to version of osbot-prefec…

…t that has support for capturing the flow and task logs
owasp-sbot · Oct 9, 2024 · 03223cb · 03223cb
1 parent 5a84d04
commit 03223cb
Show file tree

Hide file tree

Showing 5 changed files with 26 additions and 22 deletions.
diff --git a/.github/workflows/ci-pipeline__dev.yml b/.github/workflows/ci-pipeline__dev.yml
@@ -21,6 +21,9 @@ env:
   PREFECT_CLOUD__ACCOUNT_ID  : ${{ secrets.PREFECT_CLOUD__ACCOUNT_ID   }}
   PREFECT_CLOUD__WORKSPACE_ID: ${{ secrets.PREFECT_CLOUD__WORKSPACE_ID }}
 
+  GSUITE__OAUTH2__DATA       : ${{ secrets.GSUITE__OAUTH2__DATA   }}
+  GDRIVE__TEMP_FOLDER        : ${{ secrets.GDRIVE__TEMP_FOLDER    }}
+
 jobs:
 
 

diff --git a/.github/workflows/ci-pipeline__main.yml b/.github/workflows/ci-pipeline__main.yml
@@ -20,6 +20,9 @@ env:
   PREFECT_CLOUD__ACCOUNT_ID  : ${{ secrets.PREFECT_CLOUD__ACCOUNT_ID   }}
   PREFECT_CLOUD__WORKSPACE_ID: ${{ secrets.PREFECT_CLOUD__WORKSPACE_ID }}
 
+  GSUITE__OAUTH2__DATA       : ${{ secrets.GSUITE__OAUTH2__DATA   }}
+  GDRIVE__TEMP_FOLDER        : ${{ secrets.GDRIVE__TEMP_FOLDER    }}
+
 jobs:
 
   run-unit-and-integration-tests:

diff --git a/osbot_serverless_flows/fast_api/Fast_API__Serverless_Flows.py b/osbot_serverless_flows/fast_api/Fast_API__Serverless_Flows.py
@@ -22,7 +22,6 @@ def flow_events_to_prefect_server(self):
     def setup__prefect_cloud(self):
         with self.flow_events_to_prefect_server()  as _:
             if _.prefect_cloud_api.prefect_rest_api.prefect_is_server_online():
-                print("*****: setup__prefect_cloud - add_event_listener")
                 _.add_event_listener()
                 self.prefect_enabled = True
 

diff --git a/osbot_serverless_flows/flows/gsuite/Flow__GSuite__Create_Presentation.py b/osbot_serverless_flows/flows/gsuite/Flow__GSuite__Create_Presentation.py
@@ -56,18 +56,17 @@ def deleting_presentation(self):
         print('deleting', self.presentation_id)
         self.gslides.presentation_delete(self.presentation_id)
 
-    @task()
-    def save_pdf_locally(self):
-        local_file = file_create_from_bytes("./test.pdf", self.pdf_bytes)
-        print(f"saved pdf into {local_file}")
+    # @task()
+    # def save_pdf_locally(self):
+    #     local_file = file_create_from_bytes("./test.pdf", self.pdf_bytes)
+    #     print(f"saved pdf into {local_file}")
 
     @flow()
     def flow__create_presentation(self) -> Flow:
         self.create_presentation    ()
         self.editing_presentation   ()
         self.creating_pdf_bytes     ()
         self.deleting_presentation  ()
-        self.save_pdf_locally       ()
         return 'all done'
 
     def run(self):

diff --git a/poetry.lock b/poetry.lock