Skip to content
Snippets Groups Projects
Commit c720058f authored by Leifur Halldor Asgeirsson's avatar Leifur Halldor Asgeirsson Committed by davebshow
Browse files

refactor _process_config_imports

parent 891f4d52
No related branches found
No related tags found
No related merge requests found
...@@ -160,11 +160,11 @@ class Cluster: ...@@ -160,11 +160,11 @@ class Cluster:
self.config.update(config) self.config.update(config)
def _process_config_imports(self, config): def _process_config_imports(self, config):
message_serializer = config.get('message_serializer', '') message_serializer = config.get('message_serializer')
provider = config.get('provider') provider = config.get('provider')
if message_serializer and isinstance(message_serializer, str): if isinstance(message_serializer, str):
config['message_serializer'] = my_import(message_serializer) config['message_serializer'] = my_import(message_serializer)
if provider and isinstance(provider, str): if isinstance(provider, str):
config['provider'] = my_import(provider) config['provider'] = my_import(provider)
return config return config
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment