Module: DirtyPipeline::PG

Defined in:
lib/dirty_pipeline/pg/storage.rb,
lib/dirty_pipeline/pg.rb,
lib/dirty_pipeline/pg/queue.rb,
lib/dirty_pipeline/pg/railway.rb

Overview

Storage structure {

status: :errored,
state: {
  field: "value",
}

}

Defined Under Namespace

Classes: Queue, Railway, Storage

Class Method Summary collapse

Class Method Details

.multi(pg_result) ⇒ Object 



4
5
6
 
# File 'lib/dirty_pipeline/pg.rb', line 4

def multi(pg_result)
  pg_result.first&.values
end

.single(pg_result) ⇒ Object 



8
9
10
 
# File 'lib/dirty_pipeline/pg.rb', line 8

def single(pg_result)
  pg_result.first&.values&.first
end