We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 12a0ca5 commit 98d2ea9Copy full SHA for 98d2ea9
lib/sequin/consumers/consumer_event_data.ex
@@ -134,9 +134,10 @@ defmodule Sequin.Consumers.ConsumerEventData do
134
map = Sequin.Map.atomize_keys(consumer)
135
struct!(ConsumerEventData.Metadata.Sink, map)
136
end)
137
- |> update_in([Access.key(:metadata), Access.key(:database)], fn database ->
138
- map = Sequin.Map.atomize_keys(database)
139
- struct!(ConsumerEventData.Metadata.Database, map)
+ |> update_in([Access.key(:metadata), Access.key(:database)], fn
+ database ->
+ map = Sequin.Map.atomize_keys(database || %{})
140
+ struct!(ConsumerEventData.Metadata.Database, map)
141
142
end
143
0 commit comments