@@ -129,28 +129,29 @@ def topic_creator(self, topic, name):
129129 self .logger .info ('Attempting to create %s item: %s' % (topic , name ))
130130
131131 if self .topic_validator (topic = topic ):
132- if topic == 'actor' :
133- item = self .get_or_create_item (model = Actor , actor_name = name )
134- self .logger .info ('Actor created: %s' % item .__repr__ )
135- elif topic == 'extract status' :
136- item = self .get_or_create_item (model = ExtractStatus , extract_status_name = name )
137- self .logger .info ('Extract Status created: %s' % item .__repr__ )
138- elif topic == 'error type' :
139- item = self .get_or_create_item (model = ErrorType , error_type_name = name )
140- self .logger .info ('Error Type created: %s' % item .__repr__ )
141- elif topic == 'process type' :
142- item = self .get_or_create_item (model = ProcessType , process_type_name = name )
143- self .logger .info ('Process Type created: %s' % item .__repr__ )
144- elif topic == 'process status' :
145- item = self .get_or_create_item (model = ProcessStatus , process_status_name = name )
146- self .logger .info ('Process Status created: %s' % item .__repr__ )
147- elif topic == 'source' :
148- item = self .get_or_create_item (model = Source , source_name = name )
149- self .logger .info ('Source created: %s' % item .__repr__ )
150- elif topic == 'tool' :
151- item = self .get_or_create_item (model = Tool , tool_name = name )
152- self .logger .info ('Tool created: %s' % item .__repr__ )
153- else :
132+ try :
133+ if topic == 'actor' :
134+ item = self .get_or_create_item (model = Actor , actor_name = name )
135+ self .logger .info ('Actor created: %s' % item .__repr__ )
136+ if topic == 'extract status' :
137+ item = self .get_or_create_item (model = ExtractStatus , extract_status_name = name )
138+ self .logger .info ('Extract Status created: %s' % item .__repr__ )
139+ if topic == 'error type' :
140+ item = self .get_or_create_item (model = ErrorType , error_type_name = name )
141+ self .logger .info ('Error Type created: %s' % item .__repr__ )
142+ if topic == 'process type' :
143+ item = self .get_or_create_item (model = ProcessType , process_type_name = name )
144+ self .logger .info ('Process Type created: %s' % item .__repr__ )
145+ if topic == 'process status' :
146+ item = self .get_or_create_item (model = ProcessStatus , process_status_name = name )
147+ self .logger .info ('Process Status created: %s' % item .__repr__ )
148+ if topic == 'source' :
149+ item = self .get_or_create_item (model = Source , source_name = name )
150+ self .logger .info ('Source created: %s' % item .__repr__ )
151+ if topic == 'tool' :
152+ item = self .get_or_create_item (model = Tool , tool_name = name )
153+ self .logger .info ('Tool created: %s' % item .__repr__ )
154+ finally :
154155 ClickException ('Invalid topic type.' ).show ()
155156
156157 self .logger .error ('Invalid topic type.' )
0 commit comments