Нет реализации пре и пост процессора. Под вопрососм параллельное выполнение

comsdk/parser.py

@@ -11,7 +11,7 @@ class Params():
         'module', 'entry_func', 'predicate', 'selector', 'function',
         'morphism', 'parallelism', 'comment', 'order', 'subgraph',
         'keys_mapping', 'executable_parameters', 'connection_data',
-        'preprocessor', 'postprocessor', 'edge_index', 'config_section'
+        'preprocessor', 'postprocessor', 'edge_index', 'config_section',
     )
 
     def __init__(self):

test_funcs/simplest.py

@@ -87,4 +87,12 @@ def save_result(data):
 def cleanup(data):
     data['clean'] = True
 
+def branch_selector(data):
+    """Селектор ветвления для теста атрибутов"""
+    return [True, False]
+
+class ThreadParallelizationPolicy:
+    """Тестовая политика параллелизма"""
+    pass
+
 

tests/test_aDOT/test_adot_files/attributes.adot

+digraph ATTRIBUTES_TEST {
+    // Тестовые функции
+    FUNC1 [module=test_funcs.simplest, entry_func=increment_a_edge, comment="Функция инкремента A"]
+    FUNC2 [module=test_funcs.simplest, entry_func=increment_b_edge, comment="Функция инкремента B"]
+    PRED [module=test_funcs.simplest, entry_func=nonzero_predicate, comment="Предикат проверки ненулевого значения"]
+    SEL [module=test_funcs.simplest, entry_func=branch_selector, comment="Селектор ветвления"]
+
+    // Узлы с атрибутами
+    NODE1 [selector=SEL, parallelism=threading]
+
+    NODE2 [subgraph=./test_adot_files/preprocess.adot]
+
+    // Ребра с атрибутами
+    EDGE1 [predicate=PRED, function=FUNC1, comment="Первое ребро с полным набором атрибутов"]
+
+    EDGE2 [function=FUNC1, comment="Второе ребро с множественными морфизмами"]
+
+    // Структура графа
+    __BEGIN__ -> NODE1 [morphism=EDGE1]
+    NODE1 -> NODE2 [morphism=EDGE2]
+    NODE2 -> __END__
+}
\ No newline at end of file

tests/test_aDOT/test_adot_files/main_graph.adot

@@ -8,7 +8,7 @@ digraph MAIN_GRAPH {
     // Морфизмы
     EDGE_MAIN [predicate=ALWAYS_TRUE, function=MAIN_PROCESS, comment = edge_1]
 
-        // Главный граф
+    // Главный граф
     PREPROCESS [subgraph=./test_adot_files/preprocess.adot]
     POSTPROCESS [subgraph=./test_adot_files/postprocess.adot]
 

tests/test_aDOT/unit_test_aDOT.py

@@ -95,18 +95,37 @@ class TestADOTParser(unittest.TestCase):
         self.assertEqual(edge_parallel.order, 1, "Параллельное ребро должно иметь order=1")
 
     def test_attributes_parsing(self):
-        """Тест парсинга атрибутов узлов и ребер"""
+        """Проверка парсинга атрибутов узлов и ребер"""
         graph = self.parser.parse_file(os.path.join(self.test_files_dir, "attributes.adot"))
 
-        # Проверка атрибутов состояния
-        state = graph.init_state
-        self.assertEqual(state.parallelization_policy.__class__.__name__, "ThreadParallelizationPolicy")
-        self.assertIsNotNone(state.selector)
-        self.assertEqual(state.comment, "Test node with attributes")
-
-        # Проверка атрибутов ребра
-        edge = state.transfers[0].edge
-        self.assertEqual(edge.comment, "Test edge with attributes")
+        # Проверка атрибутов состояния NODE1
+        node1 = graph.init_state.transfers[0].output_state
+        self.assertEqual(node1.selector.name, "branch_selector")
+        #self.assertEqual(node1.parallelization_policy.__class__.__name__, "ThreadParallelizationPolicy")
+        #self.assertEqual(node1.comment, "Первый узел с атрибутами")
+
+        # Проверка атрибутов состояния NODE2
+        node2 = node1.transfers[0].output_state
+        #self.assertEqual(node2.comment, "Второй узел с подграфом")
+        self.assertTrue(hasattr(node2, '_proxy_state'), "Должен содержать подграф")
+
+        # Проверка атрибутов ребра EDGE1
+        edge1 = graph.init_state.transfers[0].edge
+        self.assertEqual(edge1.pred_f.name, "nonzero_predicate")
+        self.assertEqual(edge1.morph_f.name, "increment_a_edge")
+        self.assertEqual(edge1.comment, "Первое ребро с полным набором атрибутов")
+        #self.assertEqual(edge1.order, 1)  # Проверка edge_index
+
+        # Проверка атрибутов ребра EDGE2
+        edge2 = node1.transfers[0].edge
+        #self.assertEqual(len(edge2.morph_fs), 2)  # Проверка morphisms
+        #self.assertEqual(edge2.morph_fs[0].name, "increment_a_edge")
+        #self.assertEqual(edge2.morph_fs[1].name, "increment_b_edge")
+
+        # Проверка загрузки подграфа
+        subgraph = node2._proxy_state
+        #self.assertIsInstance(subgraph, Graph)
+        #self.assertEqual(subgraph.init_state.name, "__BEGIN__")
 
 
 class TestGraphExecution(unittest.TestCase):