Как получить доступ к атрибуту log_filepath в «Сведениях об экземпляре задачи» воздушного потока Apache - PullRequest
Новая
       2

Как получить доступ к атрибуту log_filepath в «Сведениях об экземпляре задачи» воздушного потока Apache

0 голосов
/ 26 марта 2019

Я могу захватить контекст экземпляра задачи в потоке apache и получить доступ из методов, но мне нужны атрибуты log_filepath абсолютного пути, но, похоже, он не передается в контексте экземпляра задачи

Я пытаюсь отправить слабое предупреждение, в котором я хочу записать некоторые дополнительные параметры из журнала задач, поэтому, пытаясь получить доступ к пути журнала и прочитать путь, я прилагаю метод здесь, где я передаю log_url 

def task_success_slack_alert(context):
    slack_webhook_token = BaseHook.get_connection(SLACK_CONN_ID).password
    slack_msg = """
            :red_circle: Task Failed. 
            *Task*: {task}  
            *Dag*: {dag} 
            *Execution Time*: {exec_date}  
            *Log Url*: {log_url}
            """.format(
            task=context.get('task_instance').task_id,
            dag=context.get('task_instance').dag_id,
            ti=context.get('task_instance'),
            exec_date=context.get('execution_date'),
            log_url=context.get('task_instance').log_url
        )

Я хочу захватить log_path во время захвата log_url, 

log_path=context.get('task_instance').log_filePath

не захватывает, похоже, что log_filePath отсутствует в качестве атрибута, но вы можете увидеть этот атрибут в пользовательском интерфейсе Airflow, вы можете увидеть атрибут

...