Skip to content

Commit 23d06ad

Browse files
committed
Improve test case formatting in Stager class
1 parent a01ae3e commit 23d06ad

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

sdks/python/apache_beam/runners/portability/stager.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -434,7 +434,7 @@ def create_and_stage_job_resources(
434434
temp_dir: Optional[str] = None,
435435
pypi_requirements: Optional[List[str]] = None,
436436
populate_requirements_cache: Optional[Callable[[str, str, bool],
437-
None]] = None,
437+
List[str]]] = None,
438438
staging_location: Optional[str] = None):
439439
"""For internal use only; no backwards-compatibility guarantees.
440440
@@ -738,7 +738,9 @@ def _get_platform_for_default_sdk_container():
738738
@retry.with_exponential_backoff(
739739
num_retries=4, retry_filter=retry_on_non_zero_exit)
740740
def _populate_requirements_cache(
741-
requirements_file, cache_dir, populate_cache_with_sdists=False) -> List[str]:
741+
requirements_file,
742+
cache_dir,
743+
populate_cache_with_sdists=False) -> List[str]:
742744
# The 'pip download' command will not download again if it finds the
743745
# tarball with the proper version already present.
744746
# It will get the packages downloaded in the order they are presented in

sdks/python/apache_beam/runners/portability/stager_test.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -100,8 +100,7 @@ def populate_requirements_cache(
100100
_ = requirements_file
101101
_ = populate_cache_with_sdists
102102
pkgs = [
103-
os.path.join(cache_dir, 'abc.txt'),
104-
os.path.join(cache_dir, 'def.txt')
103+
os.path.join(cache_dir, 'abc.txt'), os.path.join(cache_dir, 'def.txt')
105104
]
106105
for pkg in pkgs:
107106
self.create_temp_file(pkg, 'nothing')

0 commit comments

Comments
 (0)