def get_execution_info(self, driver_id, function_descriptor):
        """Get the FunctionExecutionInfo of a remote function.

        Args:
            driver_id: ID of the driver that the function belongs to.
            function_descriptor: The FunctionDescriptor of the function to get.

        Returns:
            A FunctionExecutionInfo object.
        """
        if self._worker.load_code_from_local:
            # Load function from local code.
            # Currently, we don't support isolating code by drivers,
            # thus always set driver ID to NIL here.
            driver_id = ray.DriverID.nil()
            if not function_descriptor.is_actor_method():
                self._load_function_from_local(driver_id, function_descriptor)
        else:
            # Load function from GCS.
            # Wait until the function to be executed has actually been
            # registered on this worker. We will push warnings to the user if
            # we spend too long in this loop.
            # The driver function may not be found in sys.path. Try to load
            # the function from GCS.
            with profiling.profile("wait_for_function"):
                self._wait_for_function(function_descriptor, driver_id)
        try:
            function_id = function_descriptor.function_id
            info = self._function_execution_info[driver_id][function_id]
        except KeyError as e:
            message = ("Error occurs in get_execution_info: "
                       "driver_id: %s, function_descriptor: %s. Message: %s" %
                       (driver_id, function_descriptor, e))
            raise KeyError(message)
        return info
def get_execution_info ( self , driver_id , function_descriptor ) : if self . _worker . load_code_from_local : driver_id = ray . DriverID . nil ( ) if not function_descriptor . is_actor_method ( ) : self . _load_function_from_local ( driver_id , function_descriptor ) else : with profiling . profile ( "wait_for_function" ) : self . _wait_for_function ( function_descriptor , driver_id ) try : function_id = function_descriptor . function_id info = self . _function_execution_info [ driver_id ] [ function_id ] except KeyError as e : message = ( "Error occurs in get_execution_info: " "driver_id: %s, function_descriptor: %s. Message: %s" % ( driver_id , function_descriptor , e ) ) raise KeyError ( message ) return info
Get the FunctionExecutionInfo of a remote function.

        Args:
            driver_id: ID of the driver that the function belongs to.
            function_descriptor: The FunctionDescriptor of the function to get.

        Returns:
            A FunctionExecutionInfo object.