Skip to content

Instantly share code, notes, and snippets.

Avatar

Andrés Felipe López afelopez

  • Omni Latam
  • Bogota - Colombia
View GitHub Profile
View dag_validation_test.py
import unittest
from airflow.models import DagBag
class TestDagIntegrity(unittest.TestCase):
LOAD_SECOND_THRESHOLD = 2
def setUp(self):
self.dagbag = DagBag()