blob: 3bfe861c07c1f530e912a7566ca93ba74691332e (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
from huey import Huey, crontab
from .. import HUEY, create_app
def create_consumer() -> Huey:
"""
Create and configure the Huey consumer.
The application is initialized, task modules are imported to register their
tasks, and the source scanner is registered with the configured periodic
schedule.
:return: Configured Huey instance.
"""
app = create_app()
from . import receiver, scanner, sender # noqa: 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()
|
