çalışmıyor ve benim hava akışı-scheduler.service dosya zamanlayıcı başlatır ve Ancak, görevler yayınlanmıyor vb benim DAG'leri bulur: Ben bir hata mesajı görüyorumhava akımını systemd zamanlayıcı düzgün çalışması için web sunucusu var
/bin/sh hakkında
ERROR - failed to execute task Command 'exec bash -c run'
benim sysconfig dosyası var:
#!/bin/bash
PATH=/opt/anaconda/anaconda3/envs/airflow_env/bin/airflow
AIRFLOW_CONFIG=/mnt/var/airflow/airflow.cfg
AIRFLOW_HOME=/mnt/var/airflow
Ve hava akışı-scheduler.service dosyasını:
[2017-10-30 18:36:13,764] {base_executor.py:50} INFO - Adding to queue: airflow run user_presence_raw_etl transform_raw_user_presence 2017-10-30T14:00:00 --local -sd /mnt/var/airflow/dags/bin/user_p
Oct 30 18:36:13 airflow[4742]: [2017-10-30 18:36:13,765] {jobs.py:1443} INFO - Heartbeating the executor
Oct 30 18:36:13 airflow[4742]: [2017-10-30 18:36:13,783] {local_executor.py:45} INFO - LocalWorker running airflow run user_presence_raw_etl transform_raw_user_presence 2017-10-30T14:00:00 --local -sd /mnt/var/airflow/dags/bin/us
Oct 30 18:36:13 airflow[4742]: /bin/sh: 1: exec: bash: not found
Oct 30 18:36:13 airflow[4742]: [2017-10-30 18:36:13,865] {local_executor.py:52} **ERROR - failed to execute task Command 'exec bash -c 'airflow run** user_presence_raw_etl transform_raw_user_presence 2017-10-30T14:00:00 --local -sd /mnt/var/airf
Oct 30 18:36:14 airflow[4742]: [2017-10-30 18:36:14,786] {jobs.py:1407} INFO - Heartbeating the process manager
Oct 30 18:36:14 airflow[4742]: [2017-10-30 18:36:14,786] {dag_processing.py:559} INFO - Processor for /mnt/var/airflow/dags/bin/prod/hourly_agent_dag.py finished
Oct 30 18:36:14 airflow[4742]: [2017-10-30 18:36:14,789] {dag_processing.py:627} INFO - Started a process (PID: 5425) to generate tasks for /mnt/var/airflow/dags/bin/prod/daily_agent_email_dag.py - logging into /mnt/var/airflow/l
Oct 30 18:36:14 airflow[4742]: [2017-10-30 18:36:14,831] {jobs.py:1000} INFO - No tasks to send to the executor
Oct 30 18:36:14 airflow[4742]: [2017-10-30 18:36:14,832] {jobs.py:1443} INFO - Heartbeating the executor
Oct 30 18:36:14 airflow[4742]: [2017-10-30 18:36:14,833] {jobs.py:1195} INFO - Executor reports user_presence_raw_etl.transform_raw_user_presence execution_date=2017-10-30 14:00:00 as failed
Evet, bir ortamım var (anaconda). Tipik olarak bir ekran oluşturarak hava akışını çalıştırıyorum, daha sonra kaynak airflow_env, ardından hava akışı zamanlayıcıyı etkinleştirir. Bu, zamanın% 100'ünde çalışır. .Service dosyası sanal ortama işaret ediyor - belki de etkinleştirilmiyor mu? Ne değiştirmeliyim? – trench
Örneğimde, hizmet dosyası, PATH =/opt/anaconda/anaconda3/envs/airflow_env/bin/airflow öğelerini işaret eden sysconfig dosyasına işaret eder. Normalde programlayıcıyı bir ekran üzerinde çalıştırdığım anaconda yolu budur. – trench
'/ opt/anaconda/anaconda3/envs/airflow_env/bin/airflow' dizgisini' $ PATH' içinde bulunan dizine bağlamayı deneyebilirsiniz. '/ Usr/local/bin'? Sadece hava akışı yürütülebilir olduğunda her şeyin beklendiği gibi çalıştığını doğrulamak için. Daha sonra, hizmet tanımınız için bunu nasıl düzelteceğimize odaklanabiliriz. – s7anley