granule_ingester/granule_ingester/main.py [189:200]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                     consumer])
            async with consumer:
                logger.info("All external dependencies have passed the health checks. Now listening to message queue.")
                await consumer.start_consuming(args.max_threads)
        except FailedHealthCheckError as e:
            logger.error(f"Quitting because not all dependencies passed the health checks: {e}")
        except LostConnectionError as e:
            logger.error(f"{e} Any messages that were being processed have been re-queued. Quitting.")
        except Exception as e:
            logger.exception(f"Shutting down because of an unrecoverable error:\n{e}")
        finally:
            sys.exit(1)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



granule_ingester/granule_ingester/main.py [226:238]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                     consumer])

            async with consumer:
                logger.info("All external dependencies have passed the health checks. Now listening to message queue.")
                await consumer.start_consuming(args.max_threads)
        except FailedHealthCheckError as e:
            logger.error(f"Quitting because not all dependencies passed the health checks: {e}")
        except LostConnectionError as e:
            logger.error(f"{e} Any messages that were being processed have been re-queued. Quitting.")
        except Exception as e:
            logger.exception(f"Shutting down because of an unrecoverable error:\n{e}")
        finally:
            sys.exit(1)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -