We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3c90167 commit e194624Copy full SHA for e194624
1 file changed
pulsar/client/client.py
@@ -1129,13 +1129,13 @@ def _launch_containers(
1129
extra_volumes = [v.strip() for v in raw.split(",") if v.strip()]
1130
1131
runnable = container_command_to_gcp_runnable("pulsar-container", pulsar_submit_container)
1132
- runnable.background = True
1133
if extra_volumes:
1134
runnable.container.volumes = extra_volumes
1135
job.task_groups[0].task_spec.runnables.append(runnable)
1136
1137
if tool_container:
1138
tool_runnable = container_command_to_gcp_runnable("tool-container", tool_container)
+ tool_runnable.background = True
1139
1140
tool_runnable.container.volumes = extra_volumes
1141
job.task_groups[0].task_spec.runnables.append(tool_runnable)
0 commit comments