Ensure config storage is loaded (#345)

dashbitco · Dec 2, 2024 · 3305b1c · 3305b1c
1 parent ddc2b19
commit 3305b1c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/broadway/topology.ex b/lib/broadway/topology.ex
@@ -50,7 +50,7 @@ defmodule Broadway.Topology do
 
     config_storage = ConfigStorage.get_module()
 
-    if function_exported?(config_storage, :setup, 0) do
+    if Code.ensure_loaded?(config_storage) and function_exported?(config_storage, :setup, 0) do
       config_storage.setup()
     end