(self)
| 593 | return self._dag |
| 594 | |
| 595 | def _log_session_info(self): |
| 596 | if self._config.coordinator.endpoint is not None: |
| 597 | logger.info( |
| 598 | "Connecting graphscope session with address: %s", |
| 599 | self._config.coordinator.endpoint, |
| 600 | ) |
| 601 | else: |
| 602 | logger.info( |
| 603 | "Initializing graphscope session with parameters: %s", |
| 604 | self._config.dumps_json(), |
| 605 | ) |
| 606 | |
| 607 | def _load_config_from_file(self, path, silent=True): |
| 608 | config_path = os.path.expandvars(os.path.expanduser(path)) |