@@ -735,16 +735,18 @@ defmodule Sequin.YamlLoader do
735735 #########################
736736
737737 defp upsert_sink_consumers ( account_id , % { "sinks" => consumers } , databases , http_endpoints ) do
738- Logger . info ( "Upserting sink consumers: #{ inspect ( consumers , pretty: true ) } " )
739-
740738 Enum . reduce_while ( consumers , { :ok , [ ] } , fn consumer , { :ok , acc } ->
741739 # This is a hack while sequences might be created while we create sinks
742740 # TODO: Excise this once sequences are removed
743741 databases = Repo . preload ( databases , [ :sequences ] , force: true )
744742
745743 case upsert_sink_consumer ( account_id , consumer , databases , http_endpoints ) do
746- { :ok , consumer } -> { :cont , { :ok , [ consumer | acc ] } }
747- { :error , error } -> { :halt , { :error , error } }
744+ { :ok , consumer } ->
745+ Logger . info ( "Upserted sink consumer" , consumer_id: consumer . id )
746+ { :cont , { :ok , [ consumer | acc ] } }
747+
748+ { :error , error } ->
749+ { :halt , { :error , error } }
748750 end
749751 end )
750752 rescue
@@ -767,7 +769,7 @@ defmodule Sequin.YamlLoader do
767769 with { :ok , params } <-
768770 Transforms . from_external_sink_consumer ( account_id , consumer_attrs , databases , http_endpoints ) ,
769771 { :ok , consumer } <- Sequin.Consumers . update_sink_consumer ( existing_consumer , params ) do
770- Logger . info ( "Updated HTTP push consumer: #{ inspect ( consumer , pretty: true ) } " )
772+ Logger . info ( "Updated HTTP push consumer" , consumer_id: consumer . id )
771773 { :ok , consumer }
772774 end
773775
@@ -776,7 +778,7 @@ defmodule Sequin.YamlLoader do
776778 Transforms . from_external_sink_consumer ( account_id , consumer_attrs , databases , http_endpoints ) ,
777779 { :ok , consumer } <-
778780 Sequin.Consumers . create_sink_consumer ( account_id , params ) do
779- Logger . info ( "Created HTTP push consumer: #{ inspect ( consumer , pretty: true ) } " )
781+ Logger . info ( "Created HTTP push consumer" , consumer_id: consumer . id )
780782 { :ok , consumer }
781783 end
782784 end
0 commit comments