Function assert_plugin_run

backend/python/pydevlake/pydevlake/testing/testing.py:201–212

(plugin: Plugin, connection: Connection, scope_config: Optional[ScopeConfig] = None)

def assert_plugin_run(plugin: Plugin, connection: Connection, scope_config: Optional[ScopeConfig] = None):
    assert_valid_plugin(plugin)
    assert_valid_connection(plugin, connection)
    groups = assert_valid_remote_scope_groups(plugin, connection)
    scope = assert_valid_remote_scopes(plugin, connection, groups[0].id)[0]
    assert_valid_domain_scopes(plugin, scope)
    scope_config = scope_config or plugin.scope_config_type()
    assert_valid_pipeline_plan(plugin, connection, scope, scope_config)
    for stream in plugin.streams:
        if isinstance(stream, type):
            stream = stream(plugin.name)
        assert_stream_run(stream, connection, scope, scope_config)