Merge pull request #1646 from Logflare/staging

Release 1.3.24
Logflare · Jul 27, 2023 · 1540fbc · 1540fbc
2 parents b6ed692 + a3f1198
commit 1540fbc
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-1.3.23
+1.3.24
diff --git a/lib/logflare/backends/adaptor/postgres_adaptor/pg_repo.ex b/lib/logflare/backends/adaptor/postgres_adaptor/pg_repo.ex
@@ -174,7 +174,7 @@ defmodule Logflare.Backends.Adaptor.PostgresAdaptor.PgRepo do
   Inserts a LogEvent into the given source backend table
   """
   @spec insert_log_event(SourceBackend.t(), LogEvent.t()) :: {:ok, PgLogEvent.t()}
-  def insert_log_event(source_backend, %LogEvent{} = log_event) do
+  def insert_log_event(%{config: config} = source_backend, %LogEvent{} = log_event) do
     repo = get_repo_module(source_backend)
     table = PostgresAdaptor.table_name(source_backend)
 
@@ -192,7 +192,7 @@ defmodule Logflare.Backends.Adaptor.PostgresAdaptor.PgRepo do
 
     changeset =
       %PgLogEvent{}
-      |> Ecto.put_meta(source: table)
+      |> Ecto.put_meta(source: table, prefix: config["schema"])
       |> PgLogEvent.changeset(params)
 
     repo.insert(changeset)