fix type error (#7887)

dagster-io · May 13, 2022 · 21b6a5e · 21b6a5e
1 parent bfbfa62
commit 21b6a5e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python_modules/libraries/dagster-k8s/dagster_k8s/executor.py b/python_modules/libraries/dagster-k8s/dagster_k8s/executor.py
@@ -111,7 +111,7 @@ def k8s_job_executor(init_context: InitExecutorContext) -> Executor:
             kubeconfig_file=run_launcher.kubeconfig_file,
         ),
         retries=RetryMode.from_config(init_context.executor_config["retries"]),  # type: ignore
-        max_concurrent=exc_cfg.get("max_concurrent"),
+        max_concurrent=check.opt_int_elem(exc_cfg, "max_concurrent"),
         should_verify_step=True,
     )