pgq.Consumer: use get_batch_cursor()
pgq.Consumer: use get_batch_cursor()

markokr/skytools,tarvip/skytools,overdrive3000/skytools,markokr/skytools,markokr/skytools,overdrive3000/skytools,overdrive3000/skytools,tarvip/skytools,tarvip/skytools