Marwan Sarieddine
10/13/2020, 9:51 PMdef is_fourth_business_day(provided_date: datetime) -> Callable[[datetime], bool]:
"""
Filter that allows events occuring on the fourth business day between 2020 and 2050.
Args:
- dt (datetime): the datetime to match
Returns:
- Callable[[datetime], bool]: a filter function
"""
def _filter_fn(dt: datetime) -> bool:
dates = pd.Series(pd.bdate_range("2020-01-01", "2050-01-01"))
valid_dates = (
dates.groupby([dates.dt.year, dates.dt.month]).nth(4).dt.date.to_numpy()
)
return dt.date() in valid_dates
return _filter_fn
(etl-embs) ~/infima/etl/mirror_embs adjust_mirror_flow_frequency ● python register.py
Traceback (most recent call last):
File "register.py", line 299, in <module>
register_flow(
File "register.py", line 292, in register_flow
flow.register(**params)
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/prefect/core/flow.py", line 1608, in register
registered_flow = client.register(
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/prefect/client/client.py", line 734, in register
serialized_flow = flow.serialize(build=build) # type: Any
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/prefect/core/flow.py", line 1445, in serialize
serialized = schema(exclude=["storage"]).dump(flow_copy)
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/marshmallow/schema.py", line 557, in dump
result = self._serialize(processed_obj, many=many)
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/marshmallow/schema.py", line 521, in _serialize
value = field_obj.serialize(attr_name, obj, accessor=self.get_attribute)
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/marshmallow/fields.py", line 316, in serialize
return self._serialize(value, attr, obj, **kwargs)
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/marshmallow/fields.py", line 571, in _serialize
return schema.dump(nested_obj, many=many)
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/marshmallow_oneofschema/one_of_schema.py", line 72, in dump
result = result_data = self._dump(obj, **kwargs)
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/marshmallow_oneofschema/one_of_schema.py", line 107, in _dump
result = schema.dump(obj, many=False, **kwargs)
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/marshmallow/schema.py", line 557, in dump
result = self._serialize(processed_obj, many=many)
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/marshmallow/schema.py", line 521, in _serialize
value = field_obj.serialize(attr_name, obj, accessor=self.get_attribute)
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/marshmallow/fields.py", line 316, in serialize
return self._serialize(value, attr, obj, **kwargs)
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/marshmallow/fields.py", line 704, in _serialize
return [self.inner._serialize(each, attr, obj, **kwargs) for each in value]
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/marshmallow/fields.py", line 704, in <listcomp>
return [self.inner._serialize(each, attr, obj, **kwargs) for each in value]
File "/Users/marwansarieddine/.pyenv/versions/3.8.5/envs/etl-embs/lib/python3.8/site-packages/prefect/utilities/serialization.py", line 397, in _serialize
raise ValidationError("Invalid function reference: {}".format(value))
marshmallow.exceptions.ValidationError: Invalid function reference: <function is_fourth_business_day at 0x120a0e790>
Jim Crist-Harif
10/13/2020, 9:52 PMMarwan Sarieddine
10/13/2020, 9:53 PMJim Crist-Harif
10/13/2020, 9:54 PMMarwan Sarieddine
10/13/2020, 9:56 PM