Test correct transactions management in the updated server's gRPC service (#746)

## Usage and product changes
Fix Python's behavior testing framework lists parsing to substitute
examples for the first element of the list. Update artifacts and
dependencies refs.

## Implementation

Author: farost

Cargo.lock

@@ -25,7 +25,7 @@ def typedb_artifact():
         artifact_name = "typedb-all-{platform}-{version}.{ext}",
         tag_source = deployment["artifact"]["release"]["download"],
         commit_source = deployment["artifact"]["snapshot"]["download"],
-        commit = "4859d4f8d7b965028c6dbea332ba2a779b97da66"
+        commit = "588d742a36b24423b40eaf05d8013c0cd188425f"
     )
 
 #def typedb_cloud_artifact():

dependencies/typedb/artifacts.bzl

@@ -35,5 +35,5 @@ def typedb_behaviour():
     git_repository(
         name = "typedb_behaviour",
         remote = "https://github.com/typedb/typedb-behaviour",
-        commit = "28e93a9eb2b411d5a3d04efb2812ff3a46363c24",  # sync-marker: do not remove this comment, this is used for sync-dependencies by @typedb_behaviour
+        commit = "3e4fe8c38e5a01ea9b198ee23c31cc832e003086",  # sync-marker: do not remove this comment, this is used for sync-dependencies by @typedb_behaviour
     )

dependencies/typedb/repositories.bzl

@@ -23,7 +23,8 @@
 
 import parse
 from behave import register_type
-from behave.model import Table
+from behave.model import Table, Row
+from behave.runner import Context
 from hamcrest import *
 from typedb.api.answer.query_type import QueryType
 from typedb.api.connection.transaction import TransactionType
@@ -190,8 +191,10 @@ def parse_query_type(value: str) -> QueryType:
 register_type(QueryType=parse_query_type)
 
 
-def parse_list(table: Table) -> list[str]:
-    return [table.headings[0]] + list(map(lambda row: row[0], table.rows))
+def parse_list(context: Context) -> list[str]:
+    table: Table = context.table
+    first_element = substitute_if_example(table.headings[0], context.active_outline)
+    return [first_element] + list(map(lambda row: row[0], table.rows))
 
 
 def parse_dict(table: Table) -> dict[str, str]:
@@ -221,6 +224,14 @@ def parse_table(table: Table) -> list[list[tuple[str, str]]]:
     return [[(table.headings[idx], row[idx]) for idx in range(len(row))] for row in table.rows]
 
 
+def substitute_if_example(text: str, outline: Row) -> str:
+    return outline[text[1:-1]] if is_example(text) else text
+
+
+def is_example(text: str) -> bool:
+    return text[0] == '<' and text[-1] == '>'
+
+
 class MayError:
 
     def __init__(self, may_error: bool, message: str = ""):

python/tests/behaviour/config/parameters.py

@@ -48,13 +48,13 @@ def step_impl(context: Context, may_error: MayError):
 
 @step("connection create databases")
 def step_impl(context: Context):
-    names = parse_list(context.table)
+    names = parse_list(context)
     create_databases(context.driver, names)
 
 
 @step("connection create databases in parallel")
 def step_impl(context: Context):
-    names = parse_list(context.table)
+    names = parse_list(context)
     assert_that(len(names), is_(less_than_or_equal_to(context.THREAD_POOL_SIZE)))
     with ThreadPoolExecutor(max_workers=context.THREAD_POOL_SIZE) as executor:
         for name in names:
@@ -75,12 +75,12 @@ def step_impl(context: Context, name: str, may_error: MayError):
 
 @step("connection delete databases")
 def step_impl(context: Context):
-    delete_databases(context.driver, names=parse_list(context.table))
+    delete_databases(context.driver, names=parse_list(context))
 
 
 @step("connection delete databases in parallel")
 def step_impl(context: Context):
-    names = parse_list(context.table)
+    names = parse_list(context)
     assert_that(len(names), is_(less_than_or_equal_to(context.THREAD_POOL_SIZE)))
     with ThreadPoolExecutor(max_workers=context.THREAD_POOL_SIZE) as executor:
         for name in names:
@@ -106,7 +106,7 @@ def step_impl(context: Context, name: str):
 
 @step("connection has databases")
 def step_impl(context: Context):
-    has_databases(context, names=parse_list(context.table))
+    has_databases(context, names=parse_list(context))
 
 
 def does_not_have_databases(context: Context, names: list[str]):
@@ -122,7 +122,7 @@ def step_impl(context: Context, name: str):
 
 @step("connection does not have databases")
 def step_impl(context: Context):
-    does_not_have_databases(context, names=parse_list(context.table))
+    does_not_have_databases(context, names=parse_list(context))
 
 
 @step("connection get database({name}) has schema")

python/tests/behaviour/connection/database/database_steps.py

@@ -42,7 +42,7 @@ def step_impl(context: Context, transaction_type: TransactionType, database_name
 
 @step("connection open transactions for database: {database_name}, of type")
 def step_impl(context: Context, database_name: str):
-    transaction_types = list(map(parse_transaction_type, parse_list(context.table)))
+    transaction_types = list(map(parse_transaction_type, parse_list(context)))
     open_transactions_of_type(context, database_name, transaction_types)
 
 
@@ -89,7 +89,7 @@ def for_each_transaction_has_type(context: Context, transaction_types: list):
 
 @step("transactions have type")
 def step_impl(context: Context):
-    transaction_types = list(map(parse_transaction_type, parse_list(context.table)))
+    transaction_types = list(map(parse_transaction_type, parse_list(context)))
     for_each_transaction_has_type(context, transaction_types)
 
 
@@ -100,7 +100,7 @@ def step_impl(context: Context, transaction_type: TransactionType):
 
 @step("connection open transactions in parallel for database: {name}, of type")
 def step_impl(context: Context, name: str):
-    types = list(map(parse_transaction_type, parse_list(context.table)))
+    types = list(map(parse_transaction_type, parse_list(context)))
     assert_that(len(types), is_(less_than_or_equal_to(context.THREAD_POOL_SIZE)))
     with ThreadPoolExecutor(max_workers=context.THREAD_POOL_SIZE) as executor:
         context.transactions_parallel = []
@@ -121,7 +121,7 @@ def step_impl(context: Context, are_open: bool):
 
 @step("transactions in parallel have type")
 def step_impl(context: Context):
-    types = list(map(parse_transaction_type, parse_list(context.table)))
+    types = list(map(parse_transaction_type, parse_list(context)))
     future_transactions = context.transactions_parallel
     assert_that(future_transactions, has_length(len(types)))
     future_transactions_iter = iter(future_transactions)

python/tests/behaviour/connection/transaction/transaction_steps.py

@@ -25,7 +25,7 @@
 
 @step("get all users")
 def step_impl(context: Context):
-    assert_collections_equal([db.name for db in context.driver.users.all()], parse_list(context.table))
+    assert_collections_equal([db.name for db in context.driver.users.all()], parse_list(context))
 
 
 @step("get all users{may_error:MayError}")

python/tests/behaviour/connection/user/user_steps.py

@@ -190,7 +190,7 @@ def step_impl(context: Context, count: int, may_error: MayError):
 def step_impl(context: Context):
     collect_answer_if_needed(context)
     column_names = context.collected_answer[0].column_names()
-    assert_that(sorted(list(column_names)), equal_to(sorted(parse_list(context.table))))
+    assert_that(sorted(list(column_names)), equal_to(sorted(parse_list(context))))
 
 
 def get_row_get_concepts(context: Context, row_index: int) -> [Concept]: