Skip to content

Commit 2cba0fb

Browse files
committed
f
1 parent 932d2c6 commit 2cba0fb

File tree

3 files changed

+10
-3
lines changed

3 files changed

+10
-3
lines changed

lib/table_sync.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ def sync(object_class, **options)
5252
if_condition: options[:if],
5353
unless_condition: options[:unless],
5454
debounce_time: options[:debounce_time],
55-
compress: options.fetch(:compress, false)
55+
compress: options.fetch(:compress, false),
5656
).register_callbacks
5757
end
5858

lib/table_sync/instrument_adapter/active_support.rb

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,14 @@ module TableSync::InstrumentAdapter
44
module ActiveSupport
55
module_function
66

7-
def notify(table:, schema:, event:, direction:, count: 1, compress: false)
7+
def notify( # rubocop:disable Metrics/ParameterLists
8+
table:,
9+
schema:,
10+
event:,
11+
direction:,
12+
count: 1,
13+
compress: false
14+
)
815
::ActiveSupport::Notifications.instrument "tablesync.#{direction}.#{event}",
916
count:,
1017
table: table.to_s,

lib/table_sync/setup/active_record.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ def define_after_commit(event)
1616
original_attributes: attributes,
1717
event:,
1818
debounce_time: options[:debounce_time],
19-
compress: options.fetch(:compress, false)
19+
compress: options.fetch(:compress, false),
2020
).publish_later
2121
end
2222
end

0 commit comments

Comments
 (0)