diff --git a/daft/context.py b/daft/context.py index 6c18ca2998..7f975ae83e 100644 --- a/daft/context.py +++ b/daft/context.py @@ -165,6 +165,12 @@ def get_or_create_runner(self) -> Runner: elif runner_config.name == "native": from daft.runners.native_runner import NativeRunner + warnings.warn( + "Daft is configured to use the new NativeRunner by default as of v0.4.0. " + "If you are encountering any regressions, please switch back to the legacy PyRunner via `daft.context.set_runner_py()` or by setting the env variable `DAFT_RUNNER=py`. " + "We appreciate you filing issues and helping make the NativeRunner better: https://github.com/Eventual-Inc/Daft/issues", + ) + assert isinstance(runner_config, _NativeRunnerConfig) self._runner = NativeRunner()