diff --git a/python/pyproject.toml b/python/pyproject.toml index fba30f6..0d84253 100644 --- a/python/pyproject.toml +++ b/python/pyproject.toml @@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta" [project] name = "ytsaurus-flyt" -version = "0.1.2" +version = "0.1.3" description = "Launch PyFlink jobs on YTsaurus Vanilla operations" keywords = ["flink", "pyflink", "ytsaurus", "vanilla-operations", "data-pipeline"] readme = "README.md" diff --git a/python/src/ytsaurus_flyt/spec.py b/python/src/ytsaurus_flyt/spec.py index d414031..4b5fdbc 100644 --- a/python/src/ytsaurus_flyt/spec.py +++ b/python/src/ytsaurus_flyt/spec.py @@ -10,7 +10,7 @@ from ytsaurus_flyt.config import FlytConfig from ytsaurus_flyt.models import JobmanagerParams, OperationParams -FLINK_STANDALONE_FLAG = "FLINK_STANDALONE" +FLINK_VANILLA_FLAG = "FLINK_VANILLA" def _split_job_command_tokens_posix(job_command: str) -> list[str]: @@ -110,7 +110,7 @@ def build_vanilla_operation_spec( **DEFAULT_ENVIRONMENT, "JAVA_HOME": config.java_home, "FLINK_ENV_JAVA_OPTS": f"-Xmx{max_heap_size_str}", - FLINK_STANDALONE_FLAG: "True", + FLINK_VANILLA_FLAG: "True", **config.extra_environment, } diff --git a/python/uv.lock b/python/uv.lock index ce11e44..1f1c4e5 100644 --- a/python/uv.lock +++ b/python/uv.lock @@ -1111,7 +1111,7 @@ wheels = [ [[package]] name = "ytsaurus-flyt" -version = "0.1.2" +version = "0.1.3" source = { editable = "." } dependencies = [ { name = "click" },