Skip to content

Commit 0a4231f

Browse files
committed
Update tensorlake version and use new RequestContext.get getter
1 parent 5e2e92c commit 0a4231f

File tree

4 files changed

+21
-19
lines changed

4 files changed

+21
-19
lines changed

indexify/poetry.lock

Lines changed: 14 additions & 14 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

indexify/pyproject.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,11 +25,11 @@ httpx = { version = "0.27.2", extras = ["http2"] }
2525
pydantic = "^2.11"
2626
prometheus-client = "^0.23.1"
2727
psutil = "^7.0.0"
28-
boto3 = "^1.40.15"
28+
boto3 = "^1.40.42"
2929
structlog = "25.4.0"
3030
# Adds function-executor binary, utils lib, sdk used in indexify-cli commands.
3131
# We need to specify the tensorlake version exactly because pip install doesn't respect poetry.lock files.
32-
tensorlake = "0.2.51"
32+
tensorlake = "0.2.52"
3333
# Uncomment the next line to use local tensorlake package (only for development!)
3434
# tensorlake = { path = "../tensorlake", develop = true }
3535
# grpcio is provided by tensorlake

indexify/tests/features/test_timeout_reset_on_progress.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,12 +14,14 @@
1414

1515
@api()
1616
@function(timeout=5)
17-
def function_with_progress_updates(ctx: RequestContext, x: int) -> str:
17+
def function_with_progress_updates(x: int) -> str:
1818
"""Function that calls update_progress multiple times during execution.
1919
2020
This function takes longer than the timeout (5 seconds) but should succeed
2121
because update_progress() calls reset the timeout.
2222
"""
23+
ctx: RequestContext = RequestContext.get()
24+
2325
# Sleep for 2 seconds, then report progress
2426
time.sleep(2)
2527
ctx.progress.update(current=1, total=4)
@@ -41,7 +43,7 @@ def function_with_progress_updates(ctx: RequestContext, x: int) -> str:
4143

4244
@api()
4345
@function(timeout=5)
44-
def function_without_progress_updates(ctx: RequestContext, x: int) -> str:
46+
def function_without_progress_updates(x: int) -> str:
4547
"""Function that sleeps longer than timeout without reporting progress.
4648
4749
This function should timeout because it doesn't call update_progress().

tensorlake

Submodule tensorlake updated 34 files

0 commit comments

Comments
 (0)