digifi_cron_penal_charges
This commit is contained in:
@@ -31,7 +31,7 @@ with DAG(
|
|||||||
schedule_interval=timedelta(minutes=1),
|
schedule_interval=timedelta(minutes=1),
|
||||||
catchup=False) as dag:
|
catchup=False) as dag:
|
||||||
t1 = PythonOperator(
|
t1 = PythonOperator(
|
||||||
task_id = "digifi_cron_penal_-charges",
|
task_id = "digifi_cron_penal_charges",
|
||||||
python_callable= DigiFiTrxPenal,
|
python_callable= DigiFiTrxPenal,
|
||||||
op_kwargs={
|
op_kwargs={
|
||||||
"api_host" : Variable.get("DIGIFI_EVENT_HOST")
|
"api_host" : Variable.get("DIGIFI_EVENT_HOST")
|
||||||
|
|||||||
Reference in New Issue
Block a user