grr/server/grr_response_server/flow_base.py
def CallFlow(self,
               flow_name=None,
               next_state=None,
               request_data=None,
               client_id=None,
               base_session_id=None,
               **kwargs):
    """Creates a new flow and send its responses to a state.

    This creates a new flow. The flow may send back many responses which will be
    queued by the framework until the flow terminates. The final status message
    will cause the entire transaction to be committed to the specified state.

    Args:
       flow_name: The name of the flow to invoke.
       next_state: The state in this flow, that responses to this message should
         go to.
       request_data: Any dict provided here will be available in the
         RequestState protobuf. The Responses object maintains a reference to
         this protobuf for use in the execution of the state method. (so you can
         access this data by responses.request). There is no format mandated on
         this data but it may be a serialized protobuf.
       client_id: If given, the flow is started for this client.
       base_session_id: A URN which will be used to build a URN.
       **kwargs: Arguments for the child flow.

    Returns:
       The flow_id of the child flow which was created.

    Raises:
      ValueError: The requested next state does not exist.
    """
    if not getattr(self, next_state):
      raise ValueError("Next state %s is invalid." % next_state)

    flow_request = rdf_flow_objects.FlowRequest(
        client_id=self.rdf_flow.client_id,
        flow_id=self.rdf_flow.flow_id,
        request_id=self.GetNextOutboundId(),
        next_state=next_state)

    if request_data is not None:
      flow_request.request_data = rdf_protodict.Dict().FromDict(request_data)

    self.flow_requests.append(flow_request)

    flow_cls = registry.FlowRegistry.FlowClassByName(flow_name)

    flow.StartFlow(
        client_id=self.rdf_flow.client_id,
        flow_cls=flow_cls,
        parent_flow_obj=self,
        **kwargs)
Creates a new flow and send its responses to a state.

    This creates a new flow. The flow may send back many responses which will be
    queued by the framework until the flow terminates. The final status message
    will cause the entire transaction to be committed to the specified state.

    Args:
       flow_name: The name of the flow to invoke.
       next_state: The state in this flow, that responses to this message should
         go to.
       request_data: Any dict provided here will be available in the
         RequestState protobuf. The Responses object maintains a reference to
         this protobuf for use in the execution of the state method. (so you can
         access this data by responses.request). There is no format mandated on
         this data but it may be a serialized protobuf.
       client_id: If given, the flow is started for this client.
       base_session_id: A URN which will be used to build a URN.
       **kwargs: Arguments for the child flow.

    Returns:
       The flow_id of the child flow which was created.

    Raises:
      ValueError: The requested next state does not exist.
    
Creates a new flow and send its responses to a state.
This creates a new flow. The flow may send back many responses which will be
queued by the framework until the flow terminates. The final status message
will cause the entire transaction to be committed to the specified state.
Creates a new flow and send its responses to a state . This creates a new flow . The flow may send back many responses which will be queued by the framework until the flow terminates . The final status message will cause the entire transaction to be committed to the specified state .
def CallFlow(self,
               flow_name=None,
               next_state=None,
               request_data=None,
               client_id=None,
               base_session_id=None,
               **kwargs):
    if not getattr(self, next_state):
      raise ValueError("Next state %s is invalid." % next_state)
    flow_request = rdf_flow_objects.FlowRequest(
        client_id=self.rdf_flow.client_id,
        flow_id=self.rdf_flow.flow_id,
        request_id=self.GetNextOutboundId(),
        next_state=next_state)
    if request_data is not None:
      flow_request.request_data = rdf_protodict.Dict().FromDict(request_data)
    self.flow_requests.append(flow_request)
    flow_cls = registry.FlowRegistry.FlowClassByName(flow_name)
    flow.StartFlow(
        client_id=self.rdf_flow.client_id,
        flow_cls=flow_cls,
        parent_flow_obj=self,
        **kwargs)
def CallFlow ( self , flow_name = None , next_state = None , request_data = None , client_id = None , base_session_id = None , ** kwargs ) : if not getattr ( self , next_state ) : raise ValueError ( "Next state %s is invalid." % next_state ) flow_request = rdf_flow_objects . FlowRequest ( client_id = self . rdf_flow . client_id , flow_id = self . rdf_flow . flow_id , request_id = self . GetNextOutboundId ( ) , next_state = next_state ) if request_data is not None : flow_request . request_data = rdf_protodict . Dict ( ) . FromDict ( request_data ) self . flow_requests . append ( flow_request ) flow_cls = registry . FlowRegistry . FlowClassByName ( flow_name ) flow . StartFlow ( client_id = self . rdf_flow . client_id , flow_cls = flow_cls , parent_flow_obj = self , ** kwargs )
Creates a new flow and send its responses to a state.
Creates a new flow and send its responses to a state .
"""Creates a new flow and send its responses to a state.

    This creates a new flow. The flow may send back many responses which will be
    queued by the framework until the flow terminates. The final status message
    will cause the entire transaction to be committed to the specified state.

    Args:
       flow_name: The name of the flow to invoke.
       next_state: The state in this flow, that responses to this message should
         go to.
       request_data: Any dict provided here will be available in the
         RequestState protobuf. The Responses object maintains a reference to
         this protobuf for use in the execution of the state method. (so you can
         access this data by responses.request). There is no format mandated on
         this data but it may be a serialized protobuf.
       client_id: If given, the flow is started for this client.
       base_session_id: A URN which will be used to build a URN.
       **kwargs: Arguments for the child flow.

    Returns:
       The flow_id of the child flow which was created.

    Raises:
      ValueError: The requested next state does not exist.
    """
The flow_id of the child flow which was created.
The flow_id of the child flow which was created .
The requested next state does not exist.
The requested next state does not exist .
ValueError
self
flow_name
The name of the flow to invoke.
The name of the flow to invoke .
next_state
The state in this flow, that responses to this message should
go to.
The state in this flow that responses to this message should go to .
request_data
Any dict provided here will be available in the
RequestState protobuf. The Responses object maintains a reference to
this protobuf for use in the execution of the state method. (so you can
access this data by responses.request). There is no format mandated on
this data but it may be a serialized protobuf.
Any dict provided here will be available in the RequestState protobuf . The Responses object maintains a reference to this protobuf for use in the execution of the state method . ( so you can access this data by responses . request ) . There is no format mandated on this data but it may be a serialized protobuf .
client_id
If given, the flow is started for this client.
If given the flow is started for this client .
base_session_id
A URN which will be used to build a URN.
A URN which will be used to build a URN .
**kwargs
Arguments for the child flow.
Arguments for the child flow .