Mark NS
02/27/2023, 11:10 AMState
object for a failed task, but I'm not sure how to do that when the task throws an exception. Any advice?
try:
state: State = trigger_sync.with_options(
name=connection.name
)(
airbyte_server=airbyte_server,
connection_id=connection.connection_id
)
except AirbyteSyncJobFailed as e:
// state is undefined
Christopher Boyd
02/27/2023, 8:06 PMtask(return_state=True)