Method run

python/graphscope/client/session.py:834–867

Run operations of `fetches`. Args: fetches: :class:`Operation` Raises: RuntimeError: Client disconnect to the service. Or run on a closed session. ValueError: If fetch is not an instance of :class:`Operation`. Or

(self, fetches)

        return dag_node

    def run(self, fetches):
        """Run operations of `fetches`.
        Args:
            fetches: :class:`Operation`

        Raises:
            RuntimeError:
                Client disconnect to the service. Or run on a closed session.

            ValueError:
                If fetch is not an instance of :class:`Operation`. Or
                the fetch has been evaluated.

            InvalidArgumentError:
                Not recognized on output type.

        Returns:
            Different values for different output types of :class:`Operation`
        """

        # There might be a deadlock without `gc.collect()`:
        #
        #  - thread 1 uses `run()` to issue grpc requests
        #  - during the process, e.g., print traceback, it triggers certain `__del__()`
        #    and that issues a `run_fetches()` again, that further requires the lock
        #  - then a deadlock been introduced.
        #
        # Thus, we simply choose to call `gc.collect()` to force those `__del__()` been
        # invoked before actually issuing the grpc request to avoid the deadlock.
        #
        gc.collect()

        with self._lock:
            return self.run_fetches(fetches)

    def run_fetches(self, fetches):
        """Run operations of `fetches` without the session lock."""