Skip to content

Commit

Permalink
try fix mypy issue
Browse files Browse the repository at this point in the history
Signed-off-by: Alex Chi Z <chi@neon.tech>
  • Loading branch information
skyzh committed Dec 18, 2024
1 parent 38c7523 commit fd8a0ce
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions test_runner/regress/test_pageserver_layer_rolling.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ async def run_worker_for_tenant(

loop = asyncio.get_running_loop()
sql = await loop.run_in_executor(
None, lambda ep=ep: ep.safe_psql("SELECT pg_current_wal_flush_lsn()")
None, lambda ep: ep.safe_psql("SELECT pg_current_wal_flush_lsn()"), ep
)
last_flush_lsn = Lsn(sql[0][0])
return last_flush_lsn
Expand All @@ -52,7 +52,7 @@ async def run_worker(env: NeonEnv, tenant_conf, entries: int) -> tuple[TenantId,
loop = asyncio.get_running_loop()
# capture tenant_conf by specifying `tenant_conf=tenant_conf`, otherwise it will be evaluated to some random value
tenant, timeline = await loop.run_in_executor(
None, lambda tenant_conf=tenant_conf, env=env: env.create_tenant(conf=tenant_conf)
None, lambda tenant_conf, env: env.create_tenant(conf=tenant_conf), tenant_conf, env
)
last_flush_lsn = await run_worker_for_tenant(env, entries, tenant)
return tenant, timeline, last_flush_lsn
Expand Down

0 comments on commit fd8a0ce

Please sign in to comment.