docs: async def init():
      """Create a connection to the Redis server."""
      global redis_conn  # pylint: disable=global-statement,invalid-name
      conn = await aioredis.create_connection(
          'redis://{}:{}'.format(
              SETTINGS.get('FLOW_EXECUTOR', {}).get('REDIS_CONNECTION', {}).get('host', 'localhost'),
              SETTINGS.get('FLOW_EXECUTOR', {}).get('REDIS_CONNECTION', {}).get('port', 56379)
          ),
          db=int(SETTINGS.get('FLOW_EXECUTOR', {}).get('REDIS_CONNECTION', {}).get('db', 1))
      )
      redis_conn = aioredis.Redis(conn)