|
21 | 21 |
|
22 | 22 | class SingularityCommandLineJob(ContainerCommandLineJob):
|
23 | 23 | @staticmethod
|
24 |
| - def get_image(dockerRequirement, pull_image, dry_run=False, force_pull=False): |
| 24 | + def get_image(dockerRequirement, pull_image, dry_run=False): |
25 | 25 | # type: (Dict[Text, Text], bool, bool) -> bool
|
26 | 26 | found = False
|
27 | 27 |
|
28 |
| - if force_pull: |
29 |
| - _logger.warn("--force-docker-pull currently not supported for singularity") |
30 |
| - |
31 | 28 | if "dockerImageId" not in dockerRequirement and "dockerPull" in dockerRequirement:
|
32 | 29 | match = re.search(pattern=r'([a-z]*://)', string=dockerRequirement["dockerPull"])
|
33 | 30 | if match:
|
@@ -72,9 +69,13 @@ def get_image(dockerRequirement, pull_image, dry_run=False, force_pull=False):
|
72 | 69 |
|
73 | 70 | return found
|
74 | 71 |
|
75 |
| - def get_from_requirements(self, r, req, pull_image, dry_run=False): |
76 |
| - # type: (Dict[Text, Text], bool, bool, bool) -> Text |
| 72 | + def get_from_requirements(self, r, req, pull_image, dry_run=False, force_pull=False): |
| 73 | + # type: (Dict[Text, Text], bool, bool, bool, bool) -> Text |
77 | 74 | # returns the filename of the Singularity image (e.g. hello-world-latest.img)
|
| 75 | + |
| 76 | + if force_pull: |
| 77 | + _logger.warn("--force-docker-pull currently not supported for singularity") |
| 78 | + |
78 | 79 | if r:
|
79 | 80 | errmsg = None
|
80 | 81 | try:
|
|
0 commit comments