compose - depends_on as object (#757)

Author: JohnPreston

ecs_composex/compose/compose_services/__init__.py

@@ -133,7 +133,12 @@ def __init__(
         self.cfn_environment = (
             import_env_variables(self.environment) if self.environment else NoValue
         )
-        self.depends_on = set_else_none("depends_on", self.definition, [], False)
+        self.depends_on: dict = set_else_none("depends_on", self.definition, {}, False)
+        if isinstance(self.depends_on, list):
+            services_names = [_s_name for _s_name in self.depends_on]
+            self.depends_on: dict = {}
+            for service_name in services_names:
+                self.depends_on[service_name] = {"condition": "service_started"}
         self.docker_labels: dict = {}
         self.import_docker_labels(self._definition)
 

ecs_composex/ecs/ecs_family/__init__.py

@@ -78,7 +78,7 @@ def __init__(self, services: list[ComposeService], family_name):
         self.managed_sidecars = []
         self.name = family_name
         self.family_hostname = self.name.replace("_", "-").lower()
-        self.services_depends_on = []
+        self.services_depends_on: dict = {}
         self.template = set_template(self)
         self.stack: ServiceStack = ServiceStack(
             self.logical_name,
@@ -585,9 +585,15 @@ def set_services_to_services_dependencies(self):
         """
         for service in self.services:
             if service.depends_on:
-                for service_depends_on in service.depends_on:
-                    if service_depends_on not in self.services_depends_on:
-                        self.services_depends_on.append(service_depends_on)
+                if not isinstance(service.depends_on, dict):
+                    raise TypeError(
+                        "Service depends_on not a dict",
+                        service.name,
+                        service.depends_on,
+                    )
+                for service_name, condition_def in service.depends_on.items():
+                    if service_name not in self.services_depends_on:
+                        self.services_depends_on[service_name] = {}
 
     @property
     def task_ephemeral_storage(self) -> int:

ecs_composex/ecs/ecs_firelens/ecs_firelens_advanced/firelens_config_sidecar.py

@@ -102,4 +102,4 @@ def __init__(
         patch_fluent_service(
             fluent_service, shared_volume, name, shared_volume.name, mount_path
         )
-        fluent_service.depends_on.append(self.name)
+        fluent_service.depends_on[self.name] = {"condition": "service_started"}

ecs_composex/ecs/ecs_firelens/firelens_managed_sidecar_service.py

@@ -186,7 +186,7 @@ def set_as_dependency_to_family_services(self, is_dependency: bool = True) -> No
             if service is self:
                 continue
             if self.name not in service.depends_on:
-                service.depends_on.append(self.name)
+                service.depends_on[self.name] = {"condition": "service_healthy"}
                 LOG.info(
                     f"{self.family.name}.{service.name} - Added {self.name} as startup dependency"
                 )

ecs_composex/ecs/ecs_stack.py

@@ -76,7 +76,7 @@ def handle_families_dependencies(
     """
     for family_def in families_post:
         _family_title, _family_name = family_def
-        for family_name in settings.families[_family_title].services_depends_on:
+        for family_name in settings.families[_family_title].services_depends_on.keys():
             for __family_title, __family_def in settings.families.items():
                 if __family_def.name == family_name:
                     family_title = __family_title

ecs_composex/ecs/managed_sidecars/__init__.py

@@ -65,13 +65,13 @@ def set_as_dependency_to_family_services(self, is_dependency: bool = False) -> N
         for service in self.family.ordered_services:
             if is_dependency:
                 if self.name not in service.depends_on:
-                    service.depends_on.append(self.name)
+                    service.depends_on[self.name] = {"condition": "service_started"}
                     LOG.info(
                         f"{self.family.name}.{service.name} - Added {self.name} as startup dependency"
                     )
             else:
                 if service.name not in self.depends_on:
-                    self.depends_on.append(service.name)
+                    self.depends_on[service.name] = {"condition": "service_started"}
                     LOG.info(
                         f"{self.family.name}.{self.name} - Added {service.name} as startup dependency"
                     )

use-cases/dynamodb/create_lookup_services_mappings_cloudmap.yml

@@ -82,8 +82,8 @@ x-dynamodb:
   tableC:
     Lookup:
       Tags:
-        - name: tableC
-        - createdbycomposex: 'True'
+        name: tableC
+        createdbycomposex: 'True'
     Services:
       app03:
         Access: RW
@@ -101,8 +101,8 @@ x-dynamodb:
   tableD:
     Lookup:
       Tags:
-        - name: tableC
-        - createdbycomposex: 'False'
+        name: tableC
+        createdbycomposex: 'False'
     Services:
       app03:
         Access: RW