You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2019/12/09 23:47:00 UTC

[jira] [Commented] (AIRFLOW-6099) Add host name to task runner log

    [ https://issues.apache.org/jira/browse/AIRFLOW-6099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992036#comment-16992036 ] 

ASF subversion and git services commented on AIRFLOW-6099:
----------------------------------------------------------

Commit e8e6b4de3756588b1a5314baf127b9af0d31bf3d in airflow's branch refs/heads/v1-10-test from Tomek
[ https://gitbox.apache.org/repos/asf?p=airflow.git;h=e8e6b4d ]

[AIRFLOW-6099] Add host name to task runner log (#6688)

(cherry picked from commit f2f8d01ba29492eeec6c669d66bb405426f42f40)


> Add host name to task runner log
> --------------------------------
>
>                 Key: AIRFLOW-6099
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-6099
>             Project: Apache Airflow
>          Issue Type: Improvement
>          Components: logging
>    Affects Versions: 1.10.7
>            Reporter: Tomasz Urbaszek
>            Priority: Minor
>             Fix For: 1.10.7
>
>
> It would be great to be able to look at log at web UI and see on what host the task was running. This is very helpful especially with celery executor using multiple workers.
>  
> [2019-11-29 10:10:41,214] \{taskinstance.py:846} INFO - Executing <Task(PubSubTopicCreateOperator): create_topic> on 2019-11-28T00:00:00+00:00
> {color:#FF0000}[2019-11-29 10:10:41,215] \{base_task_runner.py:125} INFO - Running on host: 78389658e938{color}
> [2019-11-29 10:10:41,216] \{base_task_runner.py:126} INFO - Running: ['airflow', 'tasks', 'run', 'example_gcp_pubsub', 'create_topic', '2019-11-28T00:00:00+00:00', '--job_id', '2', '--pool', 'default_pool', '--raw', '-sd', '/opt/airflow/airflow/providers/google/cloud/example_dags/example_pubsub.py', '--cfg_path', '/tmp/tmpwrwdlsdv']



--
This message was sent by Atlassian Jira
(v8.3.4#803005)