diff options
Diffstat (limited to 'bin/emq-scheduler')
| -rwxr-xr-x | bin/emq-scheduler | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/bin/emq-scheduler b/bin/emq-scheduler index 31f7152..3286c63 100755 --- a/bin/emq-scheduler +++ b/bin/emq-scheduler | |||
| @@ -1,18 +1,19 @@ | |||
| 1 | #!/usr/bin/env python | 1 | #!/usr/bin/env python |
| 2 | # -*- mode: python -*- | 2 | # -*- mode: python -*- |
| 3 | import argparse | 3 | import argparse |
| 4 | from eventmq import conf | ||
| 4 | from eventmq.scheduler import Scheduler | 5 | from eventmq.scheduler import Scheduler |
| 5 | 6 | ||
| 6 | if __name__ == "__main__": | 7 | if __name__ == "__main__": |
| 7 | parser = argparse.ArgumentParser( | 8 | parser = argparse.ArgumentParser( |
| 8 | description='Listen for scheduled jobs and run them') | 9 | description='Listen for scheduled jobs and run them') |
| 9 | parser.add_argument('--config', '-C', type=str, nargs='?', | 10 | parser.add_argument('--config', '-C', type=str, nargs='?', |
| 10 | help='manually specify the location of eventmq.conf') | 11 | help='manually specify the location of eventmq.conf') |
| 11 | 12 | ||
| 12 | args = parser.parse_args() | 13 | args = parser.parse_args() |
| 13 | 14 | ||
| 14 | if args.config: | 15 | if args.config: |
| 15 | conf.CONFIG_FILE = args.config | 16 | conf.CONFIG_FILE = args.config |
| 16 | 17 | ||
| 17 | s = Scheduler() | 18 | s = Scheduler() |
| 18 | s.scheduler_main() | 19 | s.scheduler_main() |