(self)
| 105 | return self._run_step_impl(dag_def) |
| 106 | |
| 107 | def fetch_logs(self): |
| 108 | if self._logs_fetching_thread is None: |
| 109 | self._logs_fetching_thread = threading.Thread( |
| 110 | target=self._fetch_logs_impl, args=() |
| 111 | ) |
| 112 | self._logs_fetching_thread.daemon = True |
| 113 | self._logs_fetching_thread.start() |
| 114 | |
| 115 | def add_lib(self, gar): |
| 116 | if self._session_id: |