Problém není v kódu databáze nebo Pythonu; Je to problém se zvýšením pocházející z Dockeru, protože databáze potřebuje nějaký čas na načtení a kontejner pythonu (consumer.py) se spouští rychleji než databáze.
Možná řešení:
docker healthcheck
čekací doba v dockeru
přidat zpoždění spotřebiteli pythonu