Test that a stream can run all 3 steps without error.
(stream: Stream, connection: Connection, scope: ToolScope, scope_config: ScopeConfig)
| 86 | |
| 87 | |
| 88 | def assert_stream_run(stream: Stream, connection: Connection, scope: ToolScope, scope_config: ScopeConfig): |
| 89 | """ |
| 90 | Test that a stream can run all 3 steps without error. |
| 91 | """ |
| 92 | ctx = make_context(connection, scope, scope_config) |
| 93 | stream.collector.run(ctx) |
| 94 | stream.extractor.run(ctx) |
| 95 | stream.convertor.run(ctx) |
| 96 | |
| 97 | |
| 98 | def assert_valid_name(plugin: Plugin): |
no test coverage detected