fix minio connection issue

build_flow.py

@@ -21,9 +21,10 @@ from prefect.task_runners import ConcurrentTaskRunner
 def stop_at_floor(floor: int) -> None:
 
     logger = get_run_logger()
-
     logger.info(f'elevator moving to floor {floor}')
+
     time.sleep(floor)
+
     logger.info(f'elevator stops on floor {floor}')
 
 
@@ -32,9 +33,18 @@ def stop_at_floor(floor: int) -> None:
       task_runner=ConcurrentTaskRunner(),
       timeout_seconds=60)
 def elevator():
+    """ This is a small sample from official doc to run tasks concurrently
+    ref: https://docs.prefect.io/latest/concepts/task-runners/
+    """
+
+    logger = get_run_logger()
+    logger.info('Elevator start.')
+
     for floor in range(5, 0, -1):
         stop_at_floor.submit(floor)
 
+    logger.info('Elevator stop.')
+
 
 def build_deployment() -> None:
     """ Deploy flow to docker-based Prefect server """
@@ -48,7 +58,7 @@ def build_deployment() -> None:
             'USE_SSL': False,
             'AWS_ACCESS_KEY_ID': 'root',
             'AWS_SECRET_ACCESS_KEY': 'minio_password',
-            'ENDPOINT_URL': 'http://127.0.0.1:9000'
+            'ENDPOINT_URL': 'http://172.28.0.2:9000'
         }
     )
 
@@ -58,7 +68,7 @@ def build_deployment() -> None:
             'use_ssl': False,
             'key': 'root',
             'secret': 'minio_password',
-            'client_kwargs': {'endpoint_url': 'http://127.0.0.1:9000'}
+            'client_kwargs': {'endpoint_url': 'http://localhost:9000'}
         }
     )
 
@@ -78,5 +88,7 @@ def build_deployment() -> None:
 
     deployment.apply()
 
+
 if __name__ == '__main__':
+
     build_deployment()