Update to use parallel testing (#395)

Author: hinthornw

js/src/tests/run_trees.int.test.ts

@@ -9,7 +9,7 @@ async function toArray<T>(iterable: AsyncIterable<T>): Promise<T[]> {
   return result;
 }
 
-test("Test post and patch run", async () => {
+test.concurrent("Test post and patch run", async () => {
   const projectName = `__test_run_tree`;
   const langchainClient = new Client({});
   const projects = await toArray(langchainClient.listProjects());

python/Makefile

@@ -7,7 +7,7 @@ tests_watch:
 	poetry run ptw --now . -- -vv -x  tests/unit_tests
 
 integration_tests:
-	poetry run pytest tests/integration_tests
+	poetry run pytest -n auto tests/integration_tests
 
 lint:
 	poetry run ruff .

python/langsmith/client.py

@@ -812,6 +812,8 @@ def _run_transform(
             run_create["inputs"] = _hide_inputs(run_create["inputs"])
         if "outputs" in run_create:
             run_create["outputs"] = _hide_outputs(run_create["outputs"])
+        if not run_create.get("start_time"):
+            run_create["start_time"] = datetime.datetime.utcnow()
         return run_create
 
     @staticmethod

python/poetry.lock

@@ -46,6 +46,7 @@ psutil = "^5.9.5"
 freezegun = "^1.2.2"
 pytest-subtests = "^0.11.0"
 pytest-watcher = "^0.3.4"
+pytest-xdist = "^3.5.0"
 
 [tool.poetry.group.lint.dependencies]
 openai = "^1.10"

python/pyproject.toml

@@ -147,7 +147,6 @@ def test_persist_update_run(
         inputs={"text": "hello world"},
         project_name=project_name,
         api_url=os.getenv("LANGCHAIN_ENDPOINT"),
-        execution_order=1,
         start_time=start_time,
         extra={"extra": "extra"},
         revision_id=revision_id,

python/tests/integration_tests/test_client.py

@@ -132,7 +132,6 @@ async def my_chain_run(text: str):
     runs_dict = {run.name: run for run in runs}
     assert runs_dict["my_chain_run"].parent_run_id is None
     assert runs_dict["my_chain_run"].run_type == "chain"
-    assert runs_dict["my_chain_run"].execution_order == 1
     assert runs_dict["my_run"].parent_run_id == runs_dict["my_chain_run"].id
     assert runs_dict["my_run"].run_type == "chain"
     assert runs_dict["my_llm_run"].parent_run_id == runs_dict["my_run"].id