(self, ctx: Context, stream_name: str, subtask: str)
| 106 | return self._run_stream(ctx, stream, 'convertor') |
| 107 | |
| 108 | def _run_stream(self, ctx: Context, stream_name: str, subtask: str): |
| 109 | stream = self.get_stream(stream_name) |
| 110 | if stream.should_run_on(ctx.scope): |
| 111 | yield from getattr(stream, subtask).run(ctx) |
| 112 | else: |
| 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: |
no test coverage detected