Skip to content

Commit 884f996

Browse files
committed
test
1 parent f832bf0 commit 884f996

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

src/main/ruby/lib/merritt_zk_job.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -253,7 +253,7 @@ def title
253253
def self.list_jobs(zk)
254254
jobs = []
255255
zk.children(DIR).sort.each do |cp|
256-
jobs.append(LegacyIngestJob.new(cp).load(zk))
256+
jobs.append(LegacyIngestJob.new(cp).load(zk).payload_object)
257257
end
258258
jobs
259259
end

src/main/ruby/lib/merritt_zk_queue_item.rb

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,6 @@ def initialize(id)
138138
end
139139

140140
def load(zk)
141-
puts "LOAD: #{dir}/#{@id}"
142141
arr = zk.get("#{dir}/#{@id}")
143142
return if arr.nil?
144143
payload = arr[0]

0 commit comments

Comments
 (0)