Joseph Loss
05/11/2021, 5:15 PMKevin Kho
Joseph Loss
05/11/2021, 6:08 PMimport prefect.context
Traceback (most recent call last):
File "D:\venv\py38\.venv\lib\site-packages\IPython\core\interactiveshell.py", line 3437, in run_code
exec(code_obj, self.user_global_ns, self.user_ns)
File "<ipython-input-4-9e439fa2ff82>", line 1, in <module>
import prefect.context
File "C:\Users\joe.loss\AppData\Local\JetBrains\Toolbox\apps\PyCharm-P\ch-0\211.7142.13\plugins\python\helpers\pydev\_pydev_bundle\pydev_import_hook.py", line 21, in do_import
module = self._system_import(name, *args, **kwargs)
ModuleNotFoundError: No module named 'prefect.context'
Kevin Kho
import prefect
then prefect.context
.Joseph Loss
05/11/2021, 8:08 PMJoseph Loss
05/11/2021, 8:09 PMFile "D:\venv\py38\.venv\lib\site-packages\IPython\core\interactiveshell.py", line 3437, in run_code
exec(code_obj, self.user_global_ns, self.user_ns)
File "<ipython-input-51-ab54c2887a26>", line 1, in <module>
prefect.context['today']
File "D:\venv\py38\.venv\lib\site-packages\prefect\utilities\collections.py", line 80, in __getitem__
return self.__dict__[key] # __dict__ expects string keys
KeyError: 'today'
Joseph Loss
05/11/2021, 8:10 PMKevin Kho
Kevin Kho
Parameter(day, default="today")
, and then you make a task where you pull a date out.Joseph Loss
05/12/2021, 3:03 PM@task(log_stdout=True, nout=2)
def fnGetPricesTiinga(tickers, assetTypes, startDate = '2015-01-01', endDate = None, freq = 'daily'):
logger = prefect.context.get("logger")
endDate = prefect.context.today
with Flow('daily-tiingo-loader') as flow:
start_date = Parameter('start_date', default='2021-05-09')
end_date = Parameter('end_date', default="today")
fnGetPricesTiinga(...,..., end_date,...)