(self, cx, batch_id, ev_id, retry_time)
Tag event for retry. (internal)
Tag event for retry. (internal)
Tag event for retry . ( internal )
def _tag_retry(self, cx, batch_id, ev_id, retry_time):
        """Tag event for retry. (internal)"""
        cx.execute("select pgq.event_retry(%s, %s, %s)",
                    [batch_id, ev_id, retry_time])
def _tag_retry ( self , cx , batch_id , ev_id , retry_time ) : cx . execute ( "select pgq.event_retry(%s, %s, %s)" , [ batch_id , ev_id , retry_time ] )