Skip to content

Commit

Permalink
Make sure process config can be passed into core
Browse files Browse the repository at this point in the history
  • Loading branch information
oldpatricka committed Sep 14, 2012
1 parent d01a7ec commit 87e59e9
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions epu/highavailability/core.py
Expand Up @@ -11,7 +11,8 @@ class HighAvailabilityCore(object):
"""Core of High Availability Service
"""

def __init__(self, CFG, pd_client_kls, process_dispatchers, process_spec, Policy, parameters=None):
def __init__(self, CFG, pd_client_kls, process_dispatchers, process_spec,
Policy, parameters=None, process_configuration=None):
"""Create HighAvailabilityCore
@param CFG - config dictionary for highavailabilty
Expand All @@ -24,6 +25,7 @@ def __init__(self, CFG, pd_client_kls, process_dispatchers, process_spec, Policy
self.provisioner_client_kls = pd_client_kls
self.process_dispatchers = process_dispatchers
self.process_spec = process_spec
self.process_configuration = process_configuration
self.process_definition_id = "ha_process_def_%s" % uuid.uuid1()
self.policy_params = parameters

Expand All @@ -32,7 +34,8 @@ def __init__(self, CFG, pd_client_kls, process_dispatchers, process_spec, Policy
self.policy = Policy(parameters=self.policy_params,
schedule_process_callback=self._schedule,
terminate_process_callback=self._terminate_upid,
process_definition_id=self.process_definition_id)
process_definition_id=self.process_definition_id,
process_configuration=self.process_configuration)
self.managed_upids = []

def apply_policy(self):
Expand Down

0 comments on commit 87e59e9

Please sign in to comment.