Krishnan Chandra
09/15/2022, 6:33 PMAnyUrl
or subclasses within the code, do you have any idea what might be causing the pickle error?Zanie
09/15/2022, 6:45 PMSettings
objectKrishnan Chandra
09/15/2022, 6:46 PM@task(retries=3, retry_delay_seconds=10)
def process_record_stream(
record_type: Type[OpenAlexBaseModel],
records: List[OpenAlexBaseModel],
batch_size: PositiveInt = DEFAULT_BATCH_SIZE,
) -> None:
print("foo")