|
41 | 41 | import hubblestack.saltoverrides
|
42 | 42 |
|
43 | 43 | log = logging.getLogger(__name__)
|
44 |
| -hubble_status = hubblestack.status.HubbleStatus(__name__, 'schedule', 'refresh_grains') |
| 44 | +HSS = hubblestack.status.HubbleStatus(__name__, 'schedule', 'refresh_grains') |
45 | 45 |
|
46 | 46 | # Importing syslog fails on windows
|
47 | 47 | if not salt.utils.platform.is_windows():
|
@@ -237,7 +237,7 @@ def getlastrunbybuckets(buckets, seconds):
|
237 | 237 | return last_run
|
238 | 238 |
|
239 | 239 |
|
240 |
| -@hubble_status.watch |
| 240 | +@HSS.watch |
241 | 241 | def schedule():
|
242 | 242 | """
|
243 | 243 | Rudimentary single-pass scheduler
|
@@ -718,7 +718,7 @@ def _setup_dirs():
|
718 | 718 | # tag='hubble:rg' will appear in the logs to differentiate this from other
|
719 | 719 | # hangtime_wrapper timers (if any)
|
720 | 720 | @hangtime_wrapper(timeout=600, repeats=True, tag='hubble:rg')
|
721 |
| -@hubble_status.watch |
| 721 | +@HSS.watch |
722 | 722 | def refresh_grains(initial=False):
|
723 | 723 | """
|
724 | 724 | Refresh the grains, pillar, utils, modules, and returners
|
@@ -793,7 +793,7 @@ def refresh_grains(initial=False):
|
793 | 793 |
|
794 | 794 | hubblestack.status.__opts__ = __opts__
|
795 | 795 | hubblestack.status.__salt__ = __salt__
|
796 |
| - hubble_status.start_sigusr1_signal_handler() |
| 796 | + HSS.start_sigusr1_signal_handler() |
797 | 797 |
|
798 | 798 | hubblestack.utils.signing.__opts__ = __opts__
|
799 | 799 | hubblestack.utils.signing.__salt__ = __salt__
|
|
0 commit comments