grr/server/grr_response_server/databases/mysql_flows.py
def _UpdateNeedsProcessing(self, requests, cursor):
    """Updates requests that have their NeedsProcessing flag set."""
    query = "UPDATE flow_requests SET needs_processing=TRUE WHERE"
    conditions = []
    args = []
    for client_id, flow_id, request_id in requests:
      conditions.append("(client_id=%s AND flow_id=%s AND request_id=%s)")
      args.append(mysql_utils.ClientIDToInt(client_id))
      args.append(mysql_utils.FlowIDToInt(flow_id))
      args.append(request_id)
    query += " OR ".join(conditions)
    cursor.execute(query, args)
Updates requests that have their NeedsProcessing flag set.
Updates requests that have their NeedsProcessing flag set.
Updates requests that have their NeedsProcessing flag set .
def _UpdateNeedsProcessing(self, requests, cursor):
    query = "UPDATE flow_requests SET needs_processing=TRUE WHERE"
    conditions = []
    args = []
    for client_id, flow_id, request_id in requests:
      conditions.append("(client_id=%s AND flow_id=%s AND request_id=%s)")
      args.append(mysql_utils.ClientIDToInt(client_id))
      args.append(mysql_utils.FlowIDToInt(flow_id))
      args.append(request_id)
    query += " OR ".join(conditions)
    cursor.execute(query, args)
def _UpdateNeedsProcessing ( self , requests , cursor ) : query = "UPDATE flow_requests SET needs_processing=TRUE WHERE" conditions = [ ] args = [ ] for client_id , flow_id , request_id in requests : conditions . append ( "(client_id=%s AND flow_id=%s AND request_id=%s)" ) args . append ( mysql_utils . ClientIDToInt ( client_id ) ) args . append ( mysql_utils . FlowIDToInt ( flow_id ) ) args . append ( request_id ) query += " OR " . join ( conditions ) cursor . execute ( query , args )
Updates requests that have their NeedsProcessing flag set.
Updates requests that have their NeedsProcessing flag set .
"""Updates requests that have their NeedsProcessing flag set."""
self
requests
cursor