Mobilizon/Mobilizon-Reshare-condividi-sui-social
1
0
Fork 0
mirror of https://github.com/Tech-Workers-Coalition-Italia/mobilizon-reshare.git synced 2025-01-15 10:07:22 +01:00
Code Issues Projects Releases Wiki Activity

scripts/scheduler.py: Pass dry_run configuration.

Browse Source
This commit is contained in:
Giacomo Leidi 2023-07-11 15:49:37 +02:00
parent b17dc556d7
commit 7bcb374891
No known key found for this signature in database
GPG Key ID: D075F59A480549C3
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
scripts/scheduler.py
View File

@ -14,23 +14,32 @@ from apscheduler.schedulers.asyncio import AsyncIOScheduler
from apscheduler.triggers.cron import CronTrigger from apscheduler.triggers.cron import CronTrigger
from mobilizon_reshare.cli import _safe_execution from mobilizon_reshare.cli import _safe_execution
from mobilizon_reshare.cli.commands.recap.main import recap from mobilizon_reshare.cli.commands.recap.main import recap as recap_main
from mobilizon_reshare.cli.commands.start.main import start from mobilizon_reshare.cli.commands.start.main import start as start_main
from mobilizon_reshare.config.command import CommandConfig from mobilizon_reshare.config.command import CommandConfig
sched = AsyncIOScheduler() sched = AsyncIOScheduler()
config = CommandConfig(dry_run=False) config = CommandConfig(dry_run=False)
async def start():
await start_main(config)
async def recap():
await recap_main(config)
# Runs "start" from Monday to Friday every 15 mins # Runs "start" from Monday to Friday every 15 mins
sched.add_job( sched.add_job(
partial(_safe_execution, partial(start, config)), partial(_safe_execution, start),
CronTrigger.from_crontab( CronTrigger.from_crontab(
os.environ.get("MOBILIZON_RESHARE_INTERVAL", "*/15 10-18 * * 0-4") os.environ.get("MOBILIZON_RESHARE_INTERVAL", "*/15 10-18 * * 1-4")
), ),
) )
# Runs "recap" once a week # Runs "recap" once a week
sched.add_job( sched.add_job(
partial(_safe_execution, partial(recap, config)), partial(_safe_execution, recap),
CronTrigger.from_crontab( CronTrigger.from_crontab(
os.environ.get("MOBILIZON_RESHARE_RECAP_INTERVAL", "5 11 * * 0") os.environ.get("MOBILIZON_RESHARE_RECAP_INTERVAL", "5 11 * * 0")
), ),