Skip to content

Timeout on realnet waiting for task #23

@Lachstec

Description

@Lachstec

For some reason, there can be timeouts in the main loop when waiting for tasks that are meant for the realnet. The corresponding line in the code is the following:

logger.info(f"Checking for consumer message in main loop for realnet...")
message = kafka_client.poll(consumer, config.sync_interval)
if message is None:
    logger.error(f"Timeout while waiting for task for realnet")
    kafka_client.close()
    exit(1)

I have the feeling that this timeout is not really necessary, since it should not be an issue if the realnet does not get messages for a timeperiod. Maybe keep this on record if issues arise in the future.

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't workingquestionFurther information is requested

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions