(self, connection: Connection, group_id: Optional[str] = None)
| 113 | logger.info(f"Skipping stream {stream.name} for scope {ctx.scope.name}") |
| 114 | |
| 115 | def make_remote_scopes(self, connection: Connection, group_id: Optional[str] = None) -> msg.RemoteScopes: |
| 116 | if group_id: |
| 117 | for tool_scope in self.remote_scopes(connection, group_id): |
| 118 | tool_scope.connection_id = connection.id |
| 119 | tool_scope.raw_data_params = raw_data_params(connection.id, tool_scope.id) |
| 120 | tool_scope.raw_data_table = self._raw_scope_table_name() |
| 121 | yield msg.RemoteScope( |
| 122 | id=tool_scope.id, |
| 123 | parent_id=group_id, |
| 124 | name=tool_scope.name, |
| 125 | data=tool_scope |
| 126 | ) |
| 127 | else: |
| 128 | yield from self.remote_scope_groups(connection) |
| 129 | |
| 130 | def make_pipeline(self, scope_config_pairs: list[ScopeConfigPair], |
| 131 | connection: Connection) -> msg.PipelineData: |
no test coverage detected