diff options
author | Alex Grönholm <alex.gronholm@nextday.fi> | 2014-06-16 18:30:10 +0300 |
---|---|---|
committer | Alex Grönholm <alex.gronholm@nextday.fi> | 2014-06-16 20:18:13 +0300 |
commit | a07a13a2cd00744c65de75b4076d26c4bb37898d (patch) | |
tree | 31e75972266ea4b163e2a483e56c8aaf05bb11b8 /examples | |
parent | bb20daf50be0a35c449568e3961790ce8b153366 (diff) | |
download | apscheduler-a07a13a2cd00744c65de75b4076d26c4bb37898d.tar.gz |
Added entry points for executors and job stores too
Added shortcut methods for configuring executors and job stores
Diffstat (limited to 'examples')
-rw-r--r-- | examples/executors/processpool.py | 3 | ||||
-rw-r--r-- | examples/jobstores/mongodb.py | 6 | ||||
-rw-r--r-- | examples/jobstores/redis_.py | 6 | ||||
-rw-r--r-- | examples/jobstores/sqlalchemy_.py | 3 |
4 files changed, 6 insertions, 12 deletions
diff --git a/examples/executors/processpool.py b/examples/executors/processpool.py index 6bff793..df1e82b 100644 --- a/examples/executors/processpool.py +++ b/examples/executors/processpool.py @@ -6,7 +6,6 @@ from datetime import datetime import os from apscheduler.schedulers.blocking import BlockingScheduler -from apscheduler.executors.pool import ProcessPoolExecutor def tick(): @@ -15,7 +14,7 @@ def tick(): if __name__ == '__main__': scheduler = BlockingScheduler() - scheduler.add_executor(ProcessPoolExecutor()) + scheduler.add_executor('processpool') scheduler.add_job(tick, 'interval', seconds=3) print('Press Ctrl+{0} to exit'.format('Break' if os.name == 'nt' else 'C')) diff --git a/examples/jobstores/mongodb.py b/examples/jobstores/mongodb.py index 36a09e0..daf07ae 100644 --- a/examples/jobstores/mongodb.py +++ b/examples/jobstores/mongodb.py @@ -10,7 +10,6 @@ import sys import os from apscheduler.schedulers.blocking import BlockingScheduler -from apscheduler.jobstores.mongodb import MongoDBJobStore def alarm(time): @@ -19,11 +18,10 @@ def alarm(time): if __name__ == '__main__': scheduler = BlockingScheduler() - jobstore = MongoDBJobStore(collection='example_jobs') + scheduler.add_jobstore('mongodb', collection='example_jobs') if len(sys.argv) > 1 and sys.argv[1] == '--clear': - jobstore.remove_all_jobs() + scheduler.remove_all_jobs() - scheduler.add_jobstore(jobstore) alarm_time = datetime.now() + timedelta(seconds=10) scheduler.add_job(alarm, 'date', run_date=alarm_time, args=[datetime.now()]) print('To clear the alarms, run this example with the --clear argument.') diff --git a/examples/jobstores/redis_.py b/examples/jobstores/redis_.py index 13f6251..169bcc1 100644 --- a/examples/jobstores/redis_.py +++ b/examples/jobstores/redis_.py @@ -10,7 +10,6 @@ import sys import os from apscheduler.schedulers.blocking import BlockingScheduler -from apscheduler.jobstores.redis import RedisJobStore def alarm(time): @@ -19,11 +18,10 @@ def alarm(time): if __name__ == '__main__': scheduler = BlockingScheduler() - jobstore = RedisJobStore(jobs_key='example.jobs', run_times_key='example.run_times') + scheduler.add_jobstore('redis', jobs_key='example.jobs', run_times_key='example.run_times') if len(sys.argv) > 1 and sys.argv[1] == '--clear': - jobstore.remove_all_jobs() + scheduler.remove_all_jobs() - scheduler.add_jobstore(jobstore) alarm_time = datetime.now() + timedelta(seconds=10) scheduler.add_job(alarm, 'date', run_date=alarm_time, args=[datetime.now()]) print('To clear the alarms, run this example with the --clear argument.') diff --git a/examples/jobstores/sqlalchemy_.py b/examples/jobstores/sqlalchemy_.py index 8951844..4db4e9c 100644 --- a/examples/jobstores/sqlalchemy_.py +++ b/examples/jobstores/sqlalchemy_.py @@ -10,7 +10,6 @@ import sys import os from apscheduler.schedulers.blocking import BlockingScheduler -from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore def alarm(time): @@ -20,7 +19,7 @@ def alarm(time): if __name__ == '__main__': scheduler = BlockingScheduler() url = sys.argv[1] if len(sys.argv) > 1 else 'sqlite:///example.sqlite' - scheduler.add_jobstore(SQLAlchemyJobStore(url)) + scheduler.add_jobstore('sqlalchemy', url=url) alarm_time = datetime.now() + timedelta(seconds=10) scheduler.add_job(alarm, 'date', run_date=alarm_time, args=[datetime.now()]) print('To clear the alarms, delete the example.sqlite file.') |