grr/server/grr_response_server/db.py
def ReadFlowForProcessing(self, client_id, flow_id, processing_time):
    """Marks a flow as being processed on this worker and returns it.

    Args:
      client_id: The client id on which this flow is running.
      flow_id: The id of the flow to read.
      processing_time: Duration that the worker has to finish processing before
        the flow is considered stuck.

    Raises:
      ValueError: The flow is already marked as being processed.

    Returns:
      And rdf_flow_objects.Flow object.
    """
Marks a flow as being processed on this worker and returns it.

    Args:
      client_id: The client id on which this flow is running.
      flow_id: The id of the flow to read.
      processing_time: Duration that the worker has to finish processing before
        the flow is considered stuck.

    Raises:
      ValueError: The flow is already marked as being processed.

    Returns:
      And rdf_flow_objects.Flow object.
    
Marks a flow as being processed on this worker and returns it.
Marks a flow as being processed on this worker and returns it .
def ReadFlowForProcessing(self, client_id, flow_id, processing_time):
def ReadFlowForProcessing ( self , client_id , flow_id , processing_time ) :
Marks a flow as being processed on this worker and returns it.
Marks a flow as being processed on this worker and returns it .
"""Marks a flow as being processed on this worker and returns it.

    Args:
      client_id: The client id on which this flow is running.
      flow_id: The id of the flow to read.
      processing_time: Duration that the worker has to finish processing before
        the flow is considered stuck.

    Raises:
      ValueError: The flow is already marked as being processed.

    Returns:
      And rdf_flow_objects.Flow object.
    """
And rdf_flow_objects.Flow object.
And rdf_flow_objects . Flow object .
The flow is already marked as being processed.
The flow is already marked as being processed .
ValueError
self
client_id
The client id on which this flow is running.
The client id on which this flow is running .
flow_id
The id of the flow to read.
The id of the flow to read .
processing_time
Duration that the worker has to finish processing before
the flow is considered stuck.
Duration that the worker has to finish processing before the flow is considered stuck .