hi, i'm using airbyte to upload some tables to snowflake and i want to send a slack message with the tables that fail, does someone know how to get that info into the slack message? i tried using HookContext.op_output_values but it didn't give what i need. does somone know how to do it? Thanks!!

@owen might know the answer?

does op_output_values not give you what you need because the op itself fails? if that's the case, a hacky thing you could do is to use the airbyte resource to query the status of the sync that failed inside your hook. this would be

context.resources.airbyte.get_job_status(job_id)

(assuming you add airbyte as a required resource key for your hook). You can get the job_id that failed by parsing the error message included on HookContext.op_exception.description, which should look like "Job failed: {job_id}". The airbyte response returned by the get_job_status function will be a dictionary that contains a bunch of information that you can parse through to get the failed tables.

ok thanks