Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion dask_jobqueue/core.py
Original file line number Diff line number Diff line change
Expand Up @@ -555,7 +555,12 @@ def _dummy_job(self):
try:
return self.job_cls(
address or "tcp://<insert-scheduler-address-here>:8786",
name="name",
# The 'name' parameter is replaced inside Job class by the
# actual Dask worker name. Using 'dummy-name here' to make it
# more clear that cluster.job_script() is similar to but not
# exactly the same script as the script submitted for each Dask
# worker
name="dummy-name",
**self._job_kwargs
)
except TypeError as exc:
Expand Down