fix: correctly recreate wait name (#16)

Toloka · Jul 19, 2024 · 9e2b296 · 9e2b296
1 parent cd9016a
commit 9e2b296
Show file tree

Hide file tree

Showing 4 changed files with 677 additions and 650 deletions.
diff --git a/dbt_af/__init__.py b/dbt_af/__init__.py
@@ -3,6 +3,6 @@
  'conf',
 ]
 
-__version__ = '0.5.2'
+__version__ = '0.5.3'
 
 from . import conf, dags # noqa
diff --git a/dbt_af_functional_tests/test_af_wait_name_too_long.py b/dbt_af_functional_tests/test_af_wait_name_too_long.py
@@ -8,7 +8,10 @@ def test_af_wait_name_is_less_250_chars(manifest):
  if node['resource_type'] == 'model':
  for dep in node['depends_on']['nodes']:
  if dep.startswith('model'):
- wait_name = f"{node['name']}__group.wait__{manifest['nodes'][dep]['name']}__for__{node['name']}"
+ dep_name = manifest['nodes'][dep]['name']
+ dep_safe_name = dep_name.replace('.', '__')
+ dep_domain_name = dep_name.split('.')[0]
+ wait_name = f'{dep_domain_name}__scheduletag__dependencies__group.wait__{dep_safe_name}'
  assert len(wait_name) <= 245
  elif node['resource_type'] == 'test':
  for dep in node['depends_on']['nodes']: