Skip to content

Commit

Permalink
support multi_workers_ready?
Browse files Browse the repository at this point in the history
  • Loading branch information
gyamxxx authored Jul 26, 2017
1 parent 10f2f67 commit eaec2d1
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions lib/fluent/plugin/out_bigquery.rb
Original file line number Diff line number Diff line change
Expand Up @@ -272,6 +272,10 @@ def start
@last_fetch_schema_time = Hash.new(0)
end

def multi_workers_ready?
true
end

def writer
@writer ||= Fluent::BigQuery::Writer.new(@log, @auth_method, {
private_key_path: @private_key_path, private_key_passphrase: @private_key_passphrase,
Expand Down

0 comments on commit eaec2d1

Please sign in to comment.