diff options
| author |   efiacor <fiachra.corcoran@est.tech> | 2020-12-11 16:19:47 +0000 |
|---|---|---|
| committer | efiacor <fiachra.corcoran@est.tech> | 2021-01-12 11:35:09 +0000 |
| commit | 5e0e87f7e86f511511d37f90242300296e7b5dc4 (patch) | |
| tree | d8ed3fc96a28cbdcd347565837e8a3fb6bcf2742 /components/pm-subscription-handler/pmsh_service/pmsh_service_main.py | |
| parent | 1e6f4d9c7ea75302f4b902dbbe13642b6d20d716 (diff) | |
[PMSH] Add retry mech for DELETE_FAILED NFs
Signed-off-by: efiacor <fiachra.corcoran@est.tech>
Change-Id: I3980f0bb43c67e192828172dafe4e7be102dcc98
Issue-ID: DCAEGEN2-2152
Diffstat (limited to 'components/pm-subscription-handler/pmsh_service/pmsh_service_main.py')
| -rwxr-xr-x | components/pm-subscription-handler/pmsh_service/pmsh_service_main.py | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/components/pm-subscription-handler/pmsh_service/pmsh_service_main.py b/components/pm-subscription-handler/pmsh_service/pmsh_service_main.py index f92fdc91..307235db 100755 --- a/components/pm-subscription-handler/pmsh_service/pmsh_service_main.py +++ b/components/pm-subscription-handler/pmsh_service/pmsh_service_main.py @@ -40,26 +40,25 @@ def main(): logger.error(f'Failed to get config and create application: {e}', exc_info=True) sys.exit(e) - app_conf_thread = PeriodicTask(10, app_conf.refresh_config) - app_conf_thread.name = 'app_conf_thread' - app_conf_thread.start() - policy_response_handler = PolicyResponseHandler(policy_mr_sub, app_conf, app) policy_response_handler_thread = PeriodicTask(25, policy_response_handler.poll_policy_topic) policy_response_handler_thread.name = 'policy_event_thread' + logger.info('Start polling PMSH_CL_INPUT topic on DMaaP MR.') + policy_response_handler_thread.start() aai_event_thread = PeriodicTask(20, process_aai_events, args=(aai_event_mr_sub, policy_mr_pub, app, app_conf)) aai_event_thread.name = 'aai_event_thread' + logger.info('Start polling for NF info on AAI-EVENT topic on DMaaP MR.') + aai_event_thread.start() - subscription_handler = SubscriptionHandler(policy_mr_pub, app, app_conf, aai_event_thread, - policy_response_handler_thread) + subscription_handler = SubscriptionHandler(policy_mr_pub, app, app_conf, aai_event_thread) - subscription_handler_thread = PeriodicTask(30, subscription_handler.execute) + subscription_handler_thread = PeriodicTask(20, subscription_handler.execute) subscription_handler_thread.name = 'sub_handler_thread' subscription_handler_thread.start() - periodic_tasks = [app_conf_thread, aai_event_thread, subscription_handler_thread, + periodic_tasks = [aai_event_thread, subscription_handler_thread, policy_response_handler_thread] signal(SIGTERM, ExitHandler(periodic_tasks=periodic_tasks, |