Skip to content

Instantly share code, notes, and snippets.

View duyet's full-sized avatar

duyet duyet

View GitHub Profile
from datetime import datetime
from airflow.models import DAG
from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.python_operator import PythonOperator
DAG_OWNER = '[email protected]'
DAG_ID = 'dag_name'
SCHEDULE_INTERVAL = '@weekly'
@duyet
duyet / udp_server.py
Created January 3, 2020 04:56 — forked from majek/udp_server.py
Simple python udp server
import logging
import socket
log = logging.getLogger('udp_server')
def udp_server(host='127.0.0.1', port=1234):
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
@duyet
duyet / test_dags.py
Created October 17, 2019 07:47 — forked from criccomini/test_dags.py
test_dags.py
import os
import unittest
from airflow.models import DagBag
class TestDags(unittest.TestCase):
"""
Generic tests that all DAGs in the repository should be able to pass.
"""
https://drive.google.com/drive/folders/1ImgU5xnmgETI8QNr3KnwZHo0-UZk-QmR?usp=sharing
https://drive.google.com/file/d/0B9Z_a3MtkjyAV1MyZGp4Nk8yWkZYYXZQend5T1N5YktId2xB/view?usp=drivesdk
https://drive.google.com/open?id=1qZgW0DZXIF7lEibK91QYrx4U1L6I3NHD
https://drive.google.com/drive/folders/1L27mrRTy7ZRqJlsWiBRKje4WZE7osToN?usp=sharing
https://drive.google.com/open?id=1shT4D9fXmBmO-SoT5gmq3UgA8ZOYeVhi
https://drive.google.com/file/d/1C59AqkbrA0YsIvJdgFn2saZTS9EuB3_j/view?usp=sharing
https://drive.google.com/file/d/1F0fbGtGs22vSu0unwLWEwfMHpcNi5B5V/view?usp=sharing