diff --git a/CHANGELOG.rst b/CHANGELOG.rst index 9b1d730cd..92c5419fe 100755 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -252,6 +252,9 @@ Added `PR #903 `_ * Add low flex scenario 'eGon2035_lowflex' `#822 `_ +* Fix depricated python-operator import + `#184 `_ + .. _PR #159: https://github.com/openego/eGon-data/pull/159 .. _PR #703: https://github.com/openego/eGon-data/pull/703 diff --git a/src/egon/data/datasets/__init__.py b/src/egon/data/datasets/__init__.py index 34254bb38..521123c43 100644 --- a/src/egon/data/datasets/__init__.py +++ b/src/egon/data/datasets/__init__.py @@ -9,7 +9,7 @@ import re from airflow.models.baseoperator import BaseOperator as Operator -from airflow.operators.python_operator import PythonOperator +from airflow.operators.python import PythonOperator from sqlalchemy import Column, ForeignKey, Integer, String, Table, orm, tuple_ from sqlalchemy.ext.declarative import declarative_base diff --git a/src/egon/data/datasets/electricity_demand_timeseries/hh_profiles.py b/src/egon/data/datasets/electricity_demand_timeseries/hh_profiles.py index 67aa44014..cf9f66298 100644 --- a/src/egon/data/datasets/electricity_demand_timeseries/hh_profiles.py +++ b/src/egon/data/datasets/electricity_demand_timeseries/hh_profiles.py @@ -126,7 +126,7 @@ import os import random -from airflow.operators.python_operator import PythonOperator +from airflow.operators.python import PythonOperator from sqlalchemy import ARRAY, Column, Float, Integer, String from sqlalchemy.dialects.postgresql import CHAR, INTEGER, REAL from sqlalchemy.ext.declarative import declarative_base diff --git a/src/egon/data/datasets/emobility/motorized_individual_travel/__init__.py b/src/egon/data/datasets/emobility/motorized_individual_travel/__init__.py index 7e264cd0b..797176fa4 100644 --- a/src/egon/data/datasets/emobility/motorized_individual_travel/__init__.py +++ b/src/egon/data/datasets/emobility/motorized_individual_travel/__init__.py @@ -77,7 +77,7 @@ import os import tarfile -from airflow.operators.python_operator import PythonOperator +from airflow.operators.python import PythonOperator from psycopg2.extensions import AsIs, register_adapter import numpy as np import pandas as pd diff --git a/src/egon/data/datasets/heat_supply/individual_heating.py b/src/egon/data/datasets/heat_supply/individual_heating.py index f0d3d4092..fa437c744 100644 --- a/src/egon/data/datasets/heat_supply/individual_heating.py +++ b/src/egon/data/datasets/heat_supply/individual_heating.py @@ -184,7 +184,7 @@ import os import random -from airflow.operators.python_operator import PythonOperator +from airflow.operators.python import PythonOperator from psycopg2.extensions import AsIs, register_adapter from sqlalchemy import ARRAY, REAL, Column, Integer, String from sqlalchemy.ext.declarative import declarative_base