dag_parser.py

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from airflow.models import Variable
from parser_reviews_yandex_maps import parser_reviews



args = {'owner': 'philipp', 'start_date': '2019-06-26', 'catchup' :False, 'max_active_runs' :1}
url = 'https://yandex.ru/maps/org/yandex/123123/'
parser_reviews_dag = DAG(
    "parser_reviews",
    schedule_interval="0 * * * *",
    default_args=args,
)
def parser_start(**kwargs):
	parser_reviews(url)


parser_reviews_task = PythonOperator(
    task_id="yandex_reviews",
    python_callable=parser_start,
    dag=parser_reviews_dag,
    provide_context=True,
    op_kwargs={
    "url": url,
    },
)

parser_reviews_task