diff --git a/da/preprocessing/era5.py b/da/preprocessing/era5.py index f71418ba9fc477106bd38896a16dad7062daa88e..fb1a802aa44fcde00083a3b83974056efd759834 100644 --- a/da/preprocessing/era5.py +++ b/da/preprocessing/era5.py @@ -5,9 +5,8 @@ import datetime as dtm from dateutil import rrule, parser from calendar import monthrange from da.preprocessing.gpcp import * -from da.tools.post_slack import print_decorator, slack_decorator +#from da.tools.post_slack import print_decorator, slack_decorator from da.tools.tempworkingdir import TempWorkingDirectory -from da.tools.post_slack import print_decorator, slack_decorator from da.tools.temploglevel import TempLogLevel from cdo import Cdo @@ -61,8 +60,7 @@ async def get_download_range(loop, starttime, endtime, outdir): p.communicate() return -@asyncio.coroutine -def download_era5(date, outputdir): +async def download_era5(date, outputdir): """Function that downloads ERA5 data, if not yet present. Downloading is done via CDS API Input: diff --git a/da/preprocessing/fire.py b/da/preprocessing/fire.py index 99a943b0a5f08be68f346dfc86fb448a791fab01..43a4f793ac4d716ea58343ba2a0b9a6629370663 100644 --- a/da/preprocessing/fire.py +++ b/da/preprocessing/fire.py @@ -7,7 +7,7 @@ import netCDF4 as nc import da.tools.io4 as io from dateutil import rrule from da.preprocessing.classes import Regional, Global -from da.tools.post_slack import print_decorator, slack_decorator +#from da.tools.post_slack import print_decorator, slack_decorator from ecmwfapi import ECMWFDataServer class Fire(Regional): diff --git a/da/preprocessing/gpcp.py b/da/preprocessing/gpcp.py index 9215e79820885db518d3b75e6f0ce291cb618597..2ad8779b72da82ab65225ebdf446e1be06d6acc7 100644 --- a/da/preprocessing/gpcp.py +++ b/da/preprocessing/gpcp.py @@ -5,7 +5,7 @@ import numpy as np import netCDF4 as nc import da.tools.io4 as io from dateutil import rrule, parser -from da.tools.post_slack import print_decorator, slack_decorator +#from da.tools.post_slack import print_decorator, slack_decorator from cdo import Cdo def check_gpcp_present(dacycle, time): diff --git a/da/preprocessing/ocean.py b/da/preprocessing/ocean.py index 7c9c303387b890973481aa28e14d4c6d2a550b56..1a55c5370be40e181b2652e68d35c81a4bb3638b 100644 --- a/da/preprocessing/ocean.py +++ b/da/preprocessing/ocean.py @@ -4,7 +4,7 @@ import numpy as np import netCDF4 as nc import da.tools.io4 as io from da.preprocessing.classes import Regional, Global -from da.tools.post_slack import print_decorator, slack_decorator +#from da.tools.post_slack import print_decorator, slack_decorator import os, sys, glob, subprocess, logging, asyncio, threading from dateutil import rrule, parser import datetime as dtm diff --git a/da/preprocessing/sib.py b/da/preprocessing/sib.py index a06045df71274525aa274e3b410b163252a00d96..09b835a415df0859863d46c4e173b8841b6a6bd7 100644 --- a/da/preprocessing/sib.py +++ b/da/preprocessing/sib.py @@ -7,7 +7,7 @@ import da.tools.io4 as io from dateutil import rrule, parser from shutil import copyfile from da.preprocessing.gpcp import * -from da.tools.post_slack import print_decorator, slack_decorator +#from da.tools.post_slack import print_decorator, slack_decorator from da.tools.tempworkingdir import TempWorkingDirectory from cdo import Cdo #from da.preprocessing.merra import process_merra as process_meteo, RANAME