Update in_sql.rb

Fixes issue #43 Signed-off-by: Johan Sjölin <[email protected]>
fluent · Jul 1, 2021 · 27b3590 · 27b3590
1 parent 8c3c593
commit 27b3590
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/fluent/plugin/in_sql.rb b/lib/fluent/plugin/in_sql.rb
@@ -192,7 +192,9 @@ def start
         socket: @socket,
         schema_search_path: @schema_search_path,
       }
-
+      # This makes the default timezone the local one if it's undefined in the timestamp field itself
+      ActiveRecord::Base.default_timezone = :local
+
       # creates subclass of ActiveRecord::Base so that it can have different
       # database configuration from ActiveRecord::Base.
       @base_model = Class.new(ActiveRecord::Base) do