import airflow
from airflow.operators.bash_operator import BashOperator
from airflow import DAG
from airflow.hooks.postgres_hook import PostgresHook
from airflow.operators.bash_operator import BashOperator
from airflow.operators.python_operator import PythonOperator
from airflow.operators.postgres_operator import PostgresOperator
import os
from datetime import datetime, timedelta
import numpy as np


default_args = {
            "owner": "airflow",
            "depends_on_past": False,
            "start_date": airflow.utils.dates.days_ago(1),
            "email": ["airflow@airflow.com"],
            "email_on_failure": False,
            "email_on_retry": False,
            "retries": 1,
            "retry_delay": timedelta(minutes=1),
            }

dag = DAG("Score_update", default_args=default_args, schedule_interval='3,33 * * * *',template_searchpath = ['/root/airflow/sql/'],max_active_runs=1)


updateOp = PostgresOperator(
                    task_id='Refresh_DailyScore',
                    postgres_conn_id='postgress_sophi',
                    sql='Score.sql',
                    params={'name':'alpa'},
                    dag=dag)

updateOp