Add syspath for schemas and change dag.owners to string

gestaogovbr · Aug 27, 2024 · 829b4bd · 829b4bd
1 parent 0f27457
commit 829b4bd
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/dou_dag_generator.py b/src/dou_dag_generator.py
@@ -387,7 +387,7 @@ def create_dag(self, specs: DAGConfig, config_file: str) -> DAG:
         doc_md = self.prepare_doc_md(specs, config_file) if specs.doc_md else None
         # DAG parameters
         default_args = {
-            "owner": specs.owner,
+            "owner": ",".join(specs.owner),
             "start_date": datetime(2021, 10, 18),
             "depends_on_past": False,
             "retries": 10,

diff --git a/src/parsers.py b/src/parsers.py
@@ -1,14 +1,17 @@
 """Abstract and concrete classes to parse DAG configuration from a file."""
 
-# from dataclasses import dataclass
 import json
 import textwrap
+import os
+import sys
+
 from typing import List, Tuple
 import yaml
 
 from airflow import Dataset
 from airflow.models import Variable
 
+sys.path.insert(0, os.path.abspath(os.path.dirname(__file__)))
 from schemas import RoDouConfig, DAGConfig