webmentions_ssg/tasks/consumer.py


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

from huey import Huey, crontab

from .. import HUEY, create_app


def create_consumer() -> Huey:
    app = create_app()

    from . import receiver, scanner, sender  # noqa: E402, F401

    schedule = crontab(
        *app.config["WEBMENTIONS_SSG_SCANNER_SCHEDULE"].split(), strict=True
    )
    HUEY.periodic_task(schedule)(scanner.scan_sources)

    return HUEY.huey


huey = create_consumer()