Function report_task_failure 

pub async fn report_task_failure(
    error_tx: &Sender<StreamError>,
    task_id: u32,
    task_name: &str,
    err: StreamError,
)

Log and send a task failure to the job error channel (logs again if send fails).