def _get_compute()

in fbpcp/service/pce_aws.py [0:0]

• 16 lines of code
• 5 McCabe index (conditional complexity)

    def _get_compute(self, pce_id: str) -> PCECompute:
        tags = {PCE_ID_KEY: pce_id}
        clusters = self.ecs_gateway.describe_clusters(tags=tags)
        cluster = clusters[0] if clusters else None
        container_definitions = self.ecs_gateway.describe_task_definitions(tags=tags)
        if container_definitions:
            container_definition = container_definitions[0]
        else:
            try:
                container_definition = self.ecs_gateway.describe_task_definition(
                    SHARED_TASK_DEFINITION_PREFIX + self.region
                )
            except Exception as err:
                # The PCE service will only be responsible for getting the resources
                # The caller will decide how to handle the case that PCE don't have the container definition
                container_definition = None
                self.logger.exception(err)
        return PCECompute(self.region, cluster, container_definition)