Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

donotmerge #1865

Closed
wants to merge 28 commits into from
Closed

donotmerge #1865

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
28 commits
Select commit Hold shift + click to select a range
90bd12a
Implement new Store interface
nfcampos Sep 25, 2024
a72afdc
Fix test
nfcampos Sep 25, 2024
595c5ea
Lint
nfcampos Sep 25, 2024
cab8a24
Spelling
hinthornw Sep 25, 2024
d449ab5
Support stringized annotations
hinthornw Sep 25, 2024
6b1bf06
String Match
hinthornw Sep 25, 2024
fd226c6
Merge pull request #1835 from langchain-ai/wfh/other_annos
nfcampos Sep 25, 2024
3bf4270
Inject store
nfcampos Sep 25, 2024
0a9cd3a
Merge BaseStore and Store
nfcampos Sep 25, 2024
4ab823f
Slots for MemoryStore
nfcampos Sep 25, 2024
ebdc989
Add tests for MemoryStore in graph
hinthornw Sep 26, 2024
6af537b
Fixes
nfcampos Sep 26, 2024
c056300
Remove unimplemented args
nfcampos Sep 26, 2024
3ee8758
Update test signature
hinthornw Sep 26, 2024
7225cc2
Lint
nfcampos Sep 26, 2024
615b06b
Remove
nfcampos Sep 26, 2024
22b7cf4
Merge branch 'wfh/add_test' of https://github.com/langchain-ai/langgr…
bracesproul Sep 26, 2024
f97db1b
Update etst
hinthornw Sep 26, 2024
2b05c41
Merge branch 'wfh/add_test' of https://github.com/langchain-ai/langgr…
bracesproul Sep 26, 2024
944676a
Update kafka test
hinthornw Sep 26, 2024
a6b4c0c
Mv to checkpoint lib
hinthornw Sep 26, 2024
ba7f706
Move to checkpoint package
hinthornw Sep 26, 2024
4664b59
Merge branch 'wfh/add_test' of https://github.com/langchain-ai/langgr…
bracesproul Sep 26, 2024
99a88eb
Lint fixes
hinthornw Sep 26, 2024
d309f58
py.typed
hinthornw Sep 26, 2024
3daae2d
Update
hinthornw Sep 26, 2024
b9cf088
doc
hinthornw Sep 26, 2024
5c07393
Merge branch 'wfh/add_test' of https://github.com/langchain-ai/langgr…
bracesproul Sep 26, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Update kafka test
  • Loading branch information
@hinthornw
hinthornw committed Sep 26, 2024
commit 944676a7a514310a8cc2ad98c6cc9c1cb7f1fd61
6 changes: 6 additions & 0 deletions libs/scheduler-kafka/tests/test_subgraph.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -194,6 +194,7 @@ async def test_subgraph_w_interrupt(
"__pregel_ensure_latest": True,
"__pregel_dedupe_tasks": True,
"__pregel_resuming": False,
'__pregel_store': None,
"__pregel_task_id": history[0].tasks[0].id,
"checkpoint_id": None,
"checkpoint_map": {
Expand Down Expand Up @@ -257,6 +258,7 @@ async def test_subgraph_w_interrupt(
"__pregel_ensure_latest": True,
"__pregel_dedupe_tasks": True,
"__pregel_resuming": False,
'__pregel_store': None,
"__pregel_task_id": history[0].tasks[0].id,
"checkpoint_id": c.config["configurable"]["checkpoint_id"],
"checkpoint_map": {
Expand Down Expand Up @@ -350,6 +352,7 @@ async def test_subgraph_w_interrupt(
"__pregel_ensure_latest": True,
"__pregel_dedupe_tasks": True,
"__pregel_resuming": False,
'__pregel_store': None,
"__pregel_task_id": history[0].tasks[0].id,
"checkpoint_id": c.config["configurable"]["checkpoint_id"],
"checkpoint_map": {
Expand Down Expand Up @@ -453,6 +456,7 @@ async def test_subgraph_w_interrupt(
"__pregel_ensure_latest": True,
"__pregel_dedupe_tasks": True,
"__pregel_resuming": True,
'__pregel_store': None,
"__pregel_task_id": history[1].tasks[0].id,
"checkpoint_id": None,
"checkpoint_map": {
Expand Down Expand Up @@ -511,6 +515,7 @@ async def test_subgraph_w_interrupt(
"__pregel_ensure_latest": True,
"__pregel_dedupe_tasks": True,
"__pregel_resuming": True,
'__pregel_store': None,
"__pregel_task_id": history[1].tasks[0].id,
"checkpoint_id": c.config["configurable"]["checkpoint_id"],
"checkpoint_map": {
Expand Down Expand Up @@ -625,6 +630,7 @@ async def test_subgraph_w_interrupt(
"__pregel_ensure_latest": True,
"__pregel_dedupe_tasks": True,
"__pregel_resuming": True,
'__pregel_store': None,
"__pregel_task_id": history[1].tasks[0].id,
"checkpoint_id": c.config["configurable"]["checkpoint_id"],
"checkpoint_map": {
Expand Down
6 changes: 6 additions & 0 deletions libs/scheduler-kafka/tests/test_subgraph_sync.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -193,6 +193,7 @@ def test_subgraph_w_interrupt(
"__pregel_ensure_latest": True,
"__pregel_dedupe_tasks": True,
"__pregel_resuming": False,
'__pregel_store': None,
"__pregel_task_id": history[0].tasks[0].id,
"checkpoint_id": None,
"checkpoint_map": {
Expand Down Expand Up @@ -254,6 +255,7 @@ def test_subgraph_w_interrupt(
"__pregel_read": None,
"__pregel_send": None,
"__pregel_ensure_latest": True,
'__pregel_store': None,
"__pregel_dedupe_tasks": True,
"__pregel_resuming": False,
"__pregel_task_id": history[0].tasks[0].id,
Expand Down Expand Up @@ -348,6 +350,7 @@ def test_subgraph_w_interrupt(
"__pregel_send": None,
"__pregel_ensure_latest": True,
"__pregel_dedupe_tasks": True,
'__pregel_store': None,
"__pregel_resuming": False,
"__pregel_task_id": history[0].tasks[0].id,
"checkpoint_id": c.config["configurable"]["checkpoint_id"],
Expand Down Expand Up @@ -450,6 +453,7 @@ def test_subgraph_w_interrupt(
"__pregel_send": None,
"__pregel_ensure_latest": True,
"__pregel_dedupe_tasks": True,
'__pregel_store': None,
"__pregel_resuming": True,
"__pregel_task_id": history[1].tasks[0].id,
"checkpoint_id": None,
Expand Down Expand Up @@ -508,6 +512,7 @@ def test_subgraph_w_interrupt(
"__pregel_send": None,
"__pregel_ensure_latest": True,
"__pregel_dedupe_tasks": True,
'__pregel_store': None,
"__pregel_resuming": True,
"__pregel_task_id": history[1].tasks[0].id,
"checkpoint_id": c.config["configurable"]["checkpoint_id"],
Expand Down Expand Up @@ -623,6 +628,7 @@ def test_subgraph_w_interrupt(
"__pregel_ensure_latest": True,
"__pregel_dedupe_tasks": True,
"__pregel_resuming": True,
'__pregel_store': None,
"__pregel_task_id": history[1].tasks[0].id,
"checkpoint_id": c.config["configurable"]["checkpoint_id"],
"checkpoint_map": {
Expand Down
Loading