@@ -365,6 +365,10 @@ def main():
365365
366366 print_step (11 , 11 , "Updating Eventstream Definition" , workspace_id = workspace_id , eventstream_id = eventstream_id , eventhouse_database_name = eventhouse_database_name )
367367 try :
368+ # Create destination-friendly names (without underscores) for eventstream
369+ eventhouse_destination_name = eventhouse_name .replace ('_' , '-' )
370+ activator_destination_name = activator_name .replace ('_' , '-' )
371+
368372 eventstream_definition_result = update_eventstream_definition (
369373 workspace_client = workspace_client ,
370374 workspace_id = workspace_id ,
@@ -375,9 +379,9 @@ def main():
375379 eventhouse_table_name = "events" ,
376380 eventhub_connection_id = eventhub_connection_id ,
377381 source_name = event_hub_name ,
378- eventhouse_name = eventhouse_name ,
382+ eventhouse_name = eventhouse_destination_name ,
379383 stream_name = eventstream_name ,
380- activator_name = activator_name ,
384+ activator_name = activator_destination_name ,
381385 activator_id = activator_id
382386 )
383387 if eventstream_definition_result is None :
0 commit comments