object for a failed task, but I'm not sure how to do that when the task throws an exception. Any advice?
Copy code
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
c
Christopher Boyd
02/27/2023, 8:06 PM
what’s the task call here? running a task by default returns just the data, to return state, it should be
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.