Skip to content

Commit

Permalink
Rename expected_jwts to input_jwts
Browse files Browse the repository at this point in the history
  • Loading branch information
rculbertson committed Jan 3, 2025
1 parent cb3983c commit da026e4
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions modal/functions.py
Original file line number Diff line number Diff line change
Expand Up @@ -181,7 +181,7 @@ async def create(
return _Invocation(client.stub, function_call_id, client, retry_context)

async def pop_function_call_outputs(
self, timeout: Optional[float], clear_on_success: bool, expected_jwts: Optional[list[str]] = None
self, timeout: Optional[float], clear_on_success: bool, input_jwts: Optional[list[str]] = None
) -> api_pb2.FunctionGetOutputsResponse:
t0 = time.time()
if timeout is None:
Expand All @@ -197,7 +197,7 @@ async def pop_function_call_outputs(
last_entry_id="0-0",
clear_on_success=clear_on_success,
requested_at=time.time(),
expected_jwts=expected_jwts,
input_jwts=input_jwts,
)
response: api_pb2.FunctionGetOutputsResponse = await retry_transient_errors(
self.stub.FunctionGetOutputs,
Expand Down Expand Up @@ -233,7 +233,7 @@ async def _get_single_output(self, expected_jwt: Optional[str] = None) -> Any:
await self.pop_function_call_outputs(
timeout=None,
clear_on_success=True,
expected_jwts=[expected_jwt] if expected_jwt else None,
input_jwts=[expected_jwt] if expected_jwt else None,
)
).outputs[0]
return await _process_result(item.result, item.data_format, self.stub, self.client)
Expand Down

0 comments on commit da026e4

Please sign in to comment.