upkload

docker_as_a_service/docker_as_a_service.py

@@ -44,6 +44,7 @@ def read_output(stream, output_queue):
 async def stream_generator(request_obj):
     import tempfile
     # Create a temporary directory
+    print('create temp dir')
     with tempfile.TemporaryDirectory(ignore_cleanup_errors=True) as temp_dir:
 
         # Construct the docker command
@@ -110,10 +111,12 @@ async def stream_generator(request_obj):
                 break
             
             await asyncio.sleep(0.5)
+        print("(daas return) ")
 
         # Get the return code
         return_code = process.returncode
         yield yield_message("(daas return code:) " + str(return_code))
+        print("(daas return code:) " + str(return_code))
 
         # print(f"Successfully downloaded video {video_id}")
         existing_file_after_download = glob.glob(os.path.join(download_folder, '**', '*'))
@@ -132,11 +135,13 @@ async def stream_generator(request_obj):
             with open(fp, "rb") as f:
                 file_bytes = f.read()
                 server_file_attach[fn] = file_bytes
-
+        print("downloaded_files")
+        print(downloaded_files)
         dsacm = DockerServiceApiComModel(
             server_message="complete",
             server_file_attach=server_file_attach,
         )
+        print("sending files")
         yield python_obj_to_pickle_file_bytes(dsacm)