INTPYTHON-447 Fix skipped tests (#32)

Author: blink1073

libs/langgraph-checkpoint-mongodb/tests/integration_tests/test_pregel.py

@@ -10635,7 +10635,6 @@ def side(state: State):
 
 
 @pytest.mark.parametrize("checkpointer_name", ALL_CHECKPOINTERS_SYNC)
-@pytest.mark.skip("Test is flaky")
 def test_stream_subgraphs_during_execution(
     request: pytest.FixtureRequest, checkpointer_name: str
 ) -> None:
@@ -12902,7 +12901,6 @@ def edit(state: JokeState):
 
 
 @pytest.mark.parametrize("checkpointer_name", ALL_CHECKPOINTERS_SYNC)
-@pytest.mark.skip('Test is flaky')
 def test_weather_subgraph(
     request: pytest.FixtureRequest, checkpointer_name: str, snapshot: SnapshotAssertion
 ) -> None:

libs/langgraph-checkpoint-mongodb/tests/integration_tests/test_pregel_async.py

@@ -9423,6 +9423,7 @@ async def side(state: State):
 
 
 @pytest.mark.parametrize("checkpointer_name", ALL_CHECKPOINTERS_ASYNC)
+@pytest.mark.parametrize('Test is flaky')
 async def test_stream_subgraphs_during_execution(checkpointer_name: str) -> None:
     class InnerState(TypedDict):
         my_key: Annotated[str, operator.add]
@@ -11630,6 +11631,7 @@ async def edit(state: JokeState):
     reason="Python 3.11+ is required for async contextvars support",
 )
 @pytest.mark.parametrize("checkpointer_name", ALL_CHECKPOINTERS_ASYNC)
+@pytest.mark.skip('Test is flaky')
 async def test_weather_subgraph(
     checkpointer_name: str, snapshot: SnapshotAssertion
 ) -> None: