summaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorAlex Grönholm <alex.gronholm@nextday.fi>2014-06-16 18:30:10 +0300
committerAlex Grönholm <alex.gronholm@nextday.fi>2014-06-16 20:18:13 +0300
commita07a13a2cd00744c65de75b4076d26c4bb37898d (patch)
tree31e75972266ea4b163e2a483e56c8aaf05bb11b8 /examples
parentbb20daf50be0a35c449568e3961790ce8b153366 (diff)
downloadapscheduler-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.py3
-rw-r--r--examples/jobstores/mongodb.py6
-rw-r--r--examples/jobstores/redis_.py6
-rw-r--r--examples/jobstores/sqlalchemy_.py3
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.')