在Airflow界面中触发任务
是指通过Airflow的用户界面（UI）来手动启动和执行任务。Airflow是一个开源的任务调度和工作流管理平台，它使用Python编写，提供了丰富的功能和灵活的配置选项，使得用户可以方便地创建、调度和监控各种复杂的工作流程。
在Airflow界面中触发任务的步骤如下：
- 登录Airflow的用户界面。
- 导航到"DAGs"页面，该页面列出了所有已定义的DAG（工作流程）。
- 在"DAGs"页面中选择要触发任务的DAG。
- 在所选DAG的详情页面中，可以看到该DAG定义的所有任务以及它们之间的依赖关系。
- 选择要触发的任务，并点击相应的触发按钮或链接。
- 确认触发任务的参数和配置选项，例如要使用的日期和时间等。
- 点击确认或触发按钮来启动所选任务的执行。
触发任务的成功执行将在Airflow界面中实时显示任务的状态和执行日志。用户可以在Airflow界面中监控任务的执行情况，并查看任务的输出结果和日志信息。
Airflow的优势在于其强大的调度功能、易于使用的用户界面、灵活的任务定义和依赖管理、可扩展的架构以及丰富的生态系统。它广泛应用于数据管道、ETL（提取、转换、加载）、机器学习模型训练和部署等场景。
推荐的腾讯云相关产品是Tencent Cloud Composer。Tencent Cloud Composer是腾讯云基于Airflow开源项目构建的托管式工作流管理服务。它提供了可靠的、高度可扩展的工作流执行环境，用户可以通过简单的界面来创建、调度和监控工作流。更多关于Tencent Cloud Composer的信息和产品介绍可以访问以下链接：Tencent Cloud Composer。
相关·内容
3回答
Apache气流不调度任务
、、、、
我已经安装了airflow(V1.9.0版本)和python2.7。为了测试它的安装是否正确，我尝试从浏览器中的交互式视图触发一个教程DAG。接口显示DAG正在运行，但调度程序没有显示任何活动。
下面是我尝试过的步骤
安装气流
pip install apache-airflow
安装密码用于设置使用fernet密钥的加密
pip install apache-airflow[crypto]
生成一个fernet_key并添加airflow.cfg文件：
from cryptography.fernet import Fernet
fernet_key= F
浏览 0提问于2018-02-02得票数 6
我在Airflow .but中创建了多个DAG，我想通过一些公共模块或DAG .Can来触发它们，我们创建了一个像Azkaban这样的工作流程，以便在该流程中列出所有调用的DAgs。
浏览 1提问于2019-03-18得票数 0
需要使用使用last_modified_dt时间戳列的oracle数据源的Airflow/Python执行每小时刷新/加载表。
在气流中，有一个airflow.models.taskinstance API，它公开来自task_instance元数据表的数据，它有以下字段(用示例数据显示)，假设第一个执行日期/时间为1/1/2020 05:00：
task_id, dag_id, execution_datetime (of dag), start_date, end_date, duration, state, ....
task_a, oracle, 1/1/2020 05:00:00,
浏览 3提问于2020-10-21得票数 0
回答已采纳
5回答
我正在尝试使用airflow来定义我想要从命令行手动触发的特定工作流。
我创建了DAG并添加了一系列任务。
dag = airflow.DAG(
"DAG_NAME",
start_date=datetime(2015, 1, 1),
schedule_interval=None,
default_args=args)
然后我在终端中运行
airflow trigger_dag DAG_NAME
什么都不会发生。调度程序正在另一个线程中运行。任何方向都是非常受欢迎的。谢谢
浏览 2提问于2016-05-05得票数 24
我得到了以下DAG
import logging
from airflow import DAG
from airflow.operators.dummy import DummyOperator
from airflow.operators.python import BranchPythonOperator
from airflow.utils.dates import days_ago
from airflow.utils.task_group import TaskGroup
def select_next_branch():
if some_condition:
浏览 6提问于2022-05-20得票数 0
回答已采纳
2回答
我在风流v2.3.0上使用了taskflow API。
我有一个DAG它有很多任务。第一个任务(TaskA)打开一个EC2实例，最后一个任务(TaskX)关闭EC2实例。
TaskA返回EC2实例的实例ID，然后TaskC使用它在两个任务之间关闭它，有任务B、C、D、...W，任何任务都可能失败。当这些任务中的任何一个失败时，我希望触发TaskX来关闭我的EC2实例。
我知道我可以在on_failure_callback中使用@dag，但问题是TaskX需要一个在进行DAG定义时不知道的EC2实例ID --它需要从TaskA的返回值中获取(参见下面的MCVE代码)。
@dag(on_failu
浏览 11提问于2022-09-16得票数 0
回答已采纳
我需要重新启动气流。我想确保我在它空闲的时候做，这样我就不会因为重新启动气流的worker组件而中断作业。 如何查看正在运行的DAG？ 我在UI中看不到任何列出当前正在运行的DAG的内容。 我在airflow命令行界面中看不到任何用于列出当前正在运行的DAG的命令。 我找到了可以连接到数据库的airflow shell，但我对Airflow内部结构的了解还不够，不知道在哪里可以看到正在运行的内容。
浏览 37提问于2020-10-20得票数 0
回答已采纳
所以我对airflow还是个新手，只是把github当做一个相当基本的推/拉工具，而不是把它用在任何更复杂的东西上。
话虽如此，现在是我想用airflow/ github做更复杂的事情的时候了。
我的组织几乎所有事情都使用Google cloud，而我目前使用magnus来触发我的预定查询。由于许多原因，我的目标是转移到airflow来执行这些任务，但我实际上试图做的是将我的源代码托管在github中，并使用gitpython找到airflow的.sql文件，然后触发我的刷新。
我似乎很难理解如何在airflow实例中‘托管’我的github存储库，然后隔离一个文件以推送到dag任务。
所以，
浏览 2提问于2020-11-25得票数 2
在DAG中是否有自定义电子邮件和发送任何任务失败的选项。有一个类似‘email _on_failure’的选项: True，但它不提供动态添加内容到电子邮件主题或正文的选项。
我的DAG将如下所示
import airflow
from airflow import DAG
from airflow.contrib.operators.databricks_operator import DatabricksSubmitRunOperator
from airflow.operators.email_operator import EmailOperator
from airflow.ope
浏览 2提问于2018-08-07得票数 7
回答已采纳
我想要有一个基本上看起来像这样的数据管道 ? 在多个任务由相应的pubsub消息触发的情况下，处理来自pubsub消息输入的数据，最后一个任务仅在所有这些工作流完成时触发。我设法使用PubSub触发整个DAG (在此guide之后对PubSub进行了修改)，但它触发整个DAG，而不是单个任务。有没有办法从外部(从Cloud Function/PubSub)触发DAG中的1个任务？ 编辑 这是我所认为的DAG代码的简化版本： import google.cloud.bigquery as bigquery
import airflow
from airflow import DAG
浏览 21提问于2021-03-23得票数 1
回答已采纳
我升级了docker镜像以使用airflow 1.10.14。airflow与helm一起部署，我有一个init-container，它执行脚本来初始化Airflow。init脚本包含命令
...
airflow upgradedb
alembic upgrade heads
...
升级失败，所以我需要回滚到以前部署的发布版本，该版本包含airflow 1.10.10版本，但现在收到alembic错误。根据搜索结果，我尝试删除alembic_version表中的行/记录。
调度程序容器中的错误如下：
sqlalchemy.exc.ProgrammingError: (psycopg2.er
浏览 22提问于2021-03-13得票数 1
我正在尝试使用Apache Airflow框架开发一个编排架构，但我不希望DAG以预定的方式运行。 我读到Apache Airflow框架可以用于服务编排。但我不需要任何调度，我只需要框架来获得工作流节点之间的编排。 可以在没有调度程序的情况下使用Apache Airflow吗？有没有其他框架(Java或Python)可以推荐给我呢？ 谢谢！:)
浏览 21提问于2019-06-12得票数 2
我想通过airflow UI修改我在dags/文件夹中创建的任务的日程安排。我找不到通过UI修改日程的方法。它可以做到吗?或者我们可以只通过修改python脚本来完成它？
浏览 0提问于2018-05-10得票数 1
1回答
我目前已经设置了Airflow并正常工作，使用CeleryExecutor作为后端来提供水平缩放。这非常有效，特别是当工作节点位于EC2上的自动伸缩组中时。 除了Airflow之外，我还使用纯芹菜来处理来自Flask/Python的简单异步任务(不需要整个管道)。到目前为止，这些普通芹菜任务的量非常小，我只是在与Flask相同的机器上运行普通芹菜工人。现在需要在系统中运行大量的普通芹菜任务，所以我也需要扩展我的普通芹菜。 要做到这一点，一种方法是在Airflow worker服务器上运行纯芹菜worker服务(从自动伸缩等方面受益)。但这似乎不是一个优雅的解决方案，因为它在同一台机器上创建了
浏览 15提问于2019-10-05得票数 1
在docs ()中给出的气流演示教程(刚刚开始使用气流进行试验测试)之后，我注意到在运行回填airflow backfill tutorial -s 2015-06-01 -e 2015-06-07时，对于某些任务存在“未满足的依赖关系”的初始抱怨。
[me@mapr001 dags]$ airflow backfill tutorial -s 2015-06-01 -e 2015-06-07
[2018-07-20 14:34:29,868] {__init__.py:45} INFO - Using executor SequentialExecutor
[2018-07-20 14:34
浏览 0提问于2018-07-21得票数 1
回答已采纳
我在Ubuntu远程服务器上用Postgres数据库成功地设置了Airflow，看起来很棒。
我能够连接到我的数据仓库(一个单独的服务器)，并轻松地将查询作为任务发出。这很简单，因为安装了Airflow的服务器实际上正在发出查询。
因为我现在只是测试Airflow，所以它安装在一个相当小和低功率的服务器上。有没有办法安排任务在我强大的Windows桌面上运行？或者，利用本地计算机下载数据/处理文件，并让Airflow知道任务已成功完成的最佳方法是什么？
浏览 12提问于2017-03-07得票数 6
回答已采纳
有一个像这样的test_dag_father：
from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.operators.dagrun_operator import TriggerDagRunOperator
from airflow.sensors.external_task_sensor import ExternalTaskSensor
from airflow.ut
浏览 3提问于2020-11-26得票数 0
1回答
我有一个在成功和失败事件中执行动作和发送通知电子邮件的airflow作业，下面是我使用的代码。
#from builtins import range
from datetime import timedelta
from airflow.models import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.utils.dates import days_ago
from airflow.operators.email_operator import EmailOperator
from
浏览 2提问于2020-10-24得票数 1
2回答
我怀疑
airflow run dag_id task_id execution_date
将运行所有上游任务，但它不会。当它看到并不是所有的依赖任务都在运行时，它将会简单地失败。如何运行特定任务及其所有依赖项？我猜这是不可能的，因为气流设计的决定，但有没有办法绕过这个？
浏览 3提问于2017-03-07得票数 11
我在airflow中创建了一个DAG，该DAG使用测试和回填命令成功运行，但当我从airflow UI手动运行它时，它会出错。有什么办法解决我的问题吗？注意，DAG在LocalExecutor中运行。
在UI Airflow中记录错误：
*** Log file isn't local.
*** Fetching here: http://:8793/log/test/start/2017-10-31T09:14:32.378718
*** Failed to fetch log file from worker.
*** Reading remote logs...
*** Uns
浏览 0提问于2017-10-31得票数 1
我知道如何使用变量动态地运行DAG的任务，在为同一个DAG触发多次运行之前，它运行得很好。
也就是说，一旦在data/to/load/ dir下创建了一个包含文件的新目录，我在某个地方编写了一个脚本，它将触发airflow variables -set dir data/to/load/$newDir，然后是airflow trigger_dag dyn_test。现在，假设在data/to/load/下创建目录"a“和"b”(类似的时间)，这将使airflow variable + airflow trigger_dag调用两次，变量集调用上有两个不同的输入(一个后缀为
浏览 4提问于2019-04-14得票数 1
我有一个报告应用程序，它使用芹菜每天处理数千个作业。每种报告类型都有一个python模块，用于封装所有作业步骤。作业采用特定于客户的参数，通常在几分钟内完成。目前，作业是由客户在创建新报告或请求刷新现有报告时按需触发的。
现在，我想添加计划，以便每天运行作业，并自动刷新报告。我知道Airflow在任务编排和调度上大放异彩。我也喜欢将我的工作表达为DAG并从任务重试中获益的想法。我可以看到如何使用Airflow来运行调度的批处理作业，但我不确定我的用例。
如果我将我的作业表示为Airflow DAG，我仍然需要为每个客户运行它们的参数化。这意味着，如果客户创建了一个新报告，我需要有一种方法来触发
浏览 0提问于2020-10-28得票数 0
按照教程，我创建了一个文件夹$AIRFLOW_HOME/ DAG，并将教程DAG文件放在那里。然后启动气流调度器。默认情况下，它是暂停的。但是如果我看一下气流调度器的输出，我看到了很多运行，试图创建DAG。它为什么一直跑？
[2018-09-10 15:49:24,123] {jobs.py:1108} INFO - No tasks to consider for execution.
[2018-09-10 15:49:24,125] {jobs.py:1538} INFO -
========================================================
浏览 1提问于2018-09-10得票数 8
回答已采纳
我正在使用SSH操作符运行气流任务。我非常确信python程序没有错误，并且在运行它时成功运行。但是，当在程序执行结束时从气流中运行时，我就会出现SIGTERM错误。
我试图通过研究各种解决方案来找出答案，但没有什么效果。我尝试将killed_task_cleanup_time = 1200从airflow.cfg文件中的60增加。还尝试将hostname_callable更改为socket:gethostname in airflow.cfg，因为我在此错误之前收到了以下警告
Warning: The recorded hostname xxx does not match this ins
浏览 21提问于2020-10-15得票数 0
我一直在尝试在气流中使用“example_subdag_operator”。在我将“start_date”更改为“datetime.now()”之后，然后手动触发一个dag运行。操作符是绿色的，但是当我放大到子程序本身时，没有执行任何操作(在图形视图中是白色的)，“Run”下拉列表是空的。\
我用师父制作的最新版本。我还测试了pip发布的版本。仍然是同样的问题\
这是个虫子吗？还是我漏掉了什么？
from datetime import datetime
from airflow.models import DAG
from airflow.operators.dummy_operator
浏览 11提问于2017-02-06得票数 0
我们创建了一个Composer v2环境，用于从v1迁移。所有的DAG代码已经调整，我们正在使用到目前为止，最新的可用图像composer-2.0.0-preview.5-airflow-2.1.4。
我们注意到，尽管CPU很轻松，内存也很大，但Web server health却是片状的(在环境监视页面上，每隔几分钟就会出现红色/绿色交替)。
为了进行测试，我删除了K8s在K8s中的webserver上的健康检查(以及启动探针)。然后，我发现有一个来自airflow-monitoring pod (10.63.129.6)的IP的呼叫，此后不久，gunicorn进程接收到一个HUP：
air
浏览 0提问于2021-11-17得票数 2
回答已采纳
1回答
我尝试记录在终止postgres挂起查询的气流中触发我的DAG的用户，但是它不起作用。你能帮帮忙吗？我遗漏了什么？当我在气流中检查日志而不是用户名时，到处都是‘无’。
utils.py (描述会话逻辑的地方)
import logging
from airflow.models.log import Log
from airflow.utils.db import create_session
from airflow.operators.python_operator import PythonOperator
from psycopg2.extras import RealDictCurs
浏览 6提问于2021-08-11得票数 0
回答已采纳
我有一个非常简单的测试DAG，如下所示：
from datetime import datetime
from airflow.models import DAG
from airflow.operators.python_operator import PythonOperator
DAG = DAG(
dag_id='scheduler_test_dag',
start_date=datetime(2017, 9, 9, 4, 0, 0, 0), #..EC2 time. Equal to 11pm hora México
max_active_runs=
浏览 0提问于2018-02-13得票数 7
我在运行服务(Airflow 2)的AWS ECS中有一个任务。我想按照他们在文档中的建议设置一个健康检查，以避免在调度器关闭时出现问题。 在我的docker-compose中，我有： scheduler:
image: my-custom-airflow2
command: scheduler
healthcheck:
test: [ "CMD-SHELL", 'airflow jobs check --job-type SchedulerJob --hostname "$${HOSTNAME}"' ]
浏览 132提问于2021-09-19得票数 0
我在airflow中有一个任务(比如taskA)，它有一堆父任务。我希望仅当任何父任务失败以及所有父任务执行完成的情况下才触发taskA。
我已经检查了所有的触发规则，但没有一个符合我的要求。我不希望使用触发规则one_failed触发任务，因为它会在所有父任务完成之前触发taskA。我可以使用一些组合或触发器规则或其他什么吗？
浏览 1提问于2019-07-15得票数 2
试图设置一个简单的电报通知，dag立即在没有日志的情况下失败，如果我使用除air字节以外的任何操作员，一切都正常，如果我删除电报操作员仍然工作良好，下面的代码，有人知道原因可能是什么吗？
from airflow import DAG
from airflow.utils.dates import days_ago
from airflow.providers.airbyte.operators.airbyte import AirbyteTriggerSyncOperator
from airflow.providers.telegram.operators.telegram import
浏览 19提问于2022-03-22得票数 0
回答已采纳
我有一个名为dss_controller的控制器守护程序
dag = DAG(
dag_id='dss_controller',
default_args={
"owner": "dss admin",
"start_date": datetime.utcnow(),
},
schedule_interval=None,
)
和一个名为dss_trigger_target_dag的目标守护程序
dag = DAG(
dag_id='dss_trigger_target_dag',
default_a
浏览 0提问于2019-07-23得票数 1
我想创建一个只能在外部触发器上运行的DAG (即，使用'airflow trigger_dag‘命令)。然而，当我这样做时，除了我想要的'scheduled_xxx‘之外，我还看到了多个'manual_xxx’DagRuns。我假设scheduled_xxx DagRuns是用来回填的？
有没有办法只创建'manual_xxx‘DagRun而不创建'scheduled_xxx’DagRuns？
我尝试了start_date (过去、datetime.now()和未来)的不同值，但得到了相同的结果。这是我的玩具DAG。
from airflow impor
浏览 4提问于2016-09-16得票数 0
1回答
我试图在测试环境中使用多个任务来测试一个守护进程。我能够测试与dag关联的单个任务，但我希望在dag中创建多个任务，并启动第一个任务。用于测试我正在使用的dag中的一个任务。
task1.run()
正在被处决。但是，当我在后台的下游有一个接一个的任务时，同样的情况就不起作用了。
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime, timedelta
default_args = {
'owner'
浏览 0提问于2018-04-24得票数 13
我有一个气流DAG，它有两个任务：
read_csv
process_file
他们自己工作得很好。我故意在熊猫数据栏中创建了一个错误，以了解on_failure_callback是如何工作的，并查看它是否被触发。从日志上看，它似乎没有：
Traceback (most recent call last):
File "/usr/local/lib/python3.7/site-packages/airflow/models/taskinstance.py", line 1197, in handle_failure
task.on_failure_
浏览 7提问于2021-01-30得票数 11
回答已采纳
在使用cloud-composer执行以下python脚本时，我在Airflow代码中的gcs2bq任务日志下获得了*** Task instance did not exist in the DB：
import datetime
import os
import csv
import pandas as pd
import pip
from airflow import models
#from airflow.contrib.operators import dataproc_operator
from airflow.operators.bash_operator import Bas
浏览 0提问于2018-11-19得票数 0
3回答
我得到了关于Airflow的一般查询
是否可以基于另一个dag文件的调度来调度一个dag文件。
例如，如果我有两个dag2，即dag1和dag2。我正在尝试是否可以在每次dag1成功时都运行dag2，否则dag2就不会运行。在气流中这是可能的吗。
浏览 0提问于2018-05-31得票数 5
我正在尝试运行一个python脚本，它登录到，然后执行一个SQL命令。我使用一个叫做气流的工具来进行工作流管理。当运行下面的代码时，我可以很好地登录到DB，但是当试图执行SQL命令时，请获得以下错误。
**AttributeError: 'NoneType' object has no attribute 'execute'**
代码：
## Login to DB
def db_log(**kwargs):
global db_con
try:
db_con = psycopg2.connect(
" dbname =
浏览 1提问于2018-05-30得票数 1
在airflow.models.BaseOperator中。您有两个默认参数：
depends_on_past=False和trigger_rule=u'all_success'
根据医生
depends_on_past (bool) -当设置为true时，任务实例将按顺序运行，同时依赖于前一个任务的调度来成功。
trigger_rule (str) -定义了应用依赖关系来触发任务的规则。
这不是一回事吗？我不明白为什么会有多余的参数。
浏览 2提问于2017-12-25得票数 4
回答已采纳
我已经创建了一个dag，该dag在Airflow UI中可用，并将其打开以运行它。运行dag后，状态显示为可重试。在那之后，我去了服务器，使用了命令"Airflow scheduler“，然后dag就成功了。
在运行dag之前，调度程序已经启动并运行，我不确定为什么会发生这种情况。当我们创建一个新的dag时，我们需要运行气流调度器吗？想知道调度器是如何工作的。
谢谢
浏览 0提问于2020-05-20得票数 1
我用的是气流1.8.1。我有一个DAG，我相信我计划每5分钟运行一次，但它没有这样做：
忽略两个成功的DAG运行，那些是手动触发的。
我查看了DAG的调度程序日志，我看到：
[2019-04-26 22:03:35,601] {jobs.py:343} DagFileProcessor839 INFO - Started process (PID=5653) to work on /usr/local/airflow/dags/retrieve_airflow_artifacts.py
[2019-04-26 22:03:35,606] {jobs.py:1525} DagFilePro
浏览 0提问于2019-04-26得票数 1
回答已采纳
在我对airflow的第一次尝试中，我尝试运行安装附带的一个示例DAGS。这是v.1.8.0。以下是我的步骤：
$ airflow trigger_dag example_bash_operator
[2017-04-19 15:32:38,391] {__init__.py:57} INFO - Using executor SequentialExecutor
[2017-04-19 15:32:38,676] {models.py:167} INFO - Filling up the DagBag from /Users/gbenison/software/kludge/airflow/
浏览 10提问于2017-04-20得票数 31
我试图在subdag创建时从父进程访问一些xcom数据，我在互联网上搜索以实现这一点，但是我没有找到任何东西。
def test(task_id):
logging.info(f' execution of task {task_id}')
def load_subdag(parent_dag_id, child_dag_id, args):
dag_subdag = DAG(
dag_id='{0}.{1}'.format(parent_dag_id, child_dag_id),
default_args=
浏览 0提问于2019-02-18得票数 8
回答已采纳
2回答
您好，我刚刚开始使用Airflow，但我无法在快速入门run：airflow run example_bash_operator runme_0 2015-01-01中完成任务。
我刚刚使用Python2.7.6创建了一个conda环境，并通过安装了airflow==1.8.0的pip安装了airflow。然后，我运行了中列出的命令。
当我尝试运行第一个任务实例时，通过查看UI，似乎什么都没有发生。以下是该命令的输出：
(airflow) ✔ se7entyse7en in ~/Projects/airflow $ airflow run example_bash_operator ru
浏览 0提问于2017-07-28得票数 3
我在我的IDE中寻找运行/调试任务和dags的最佳方法。我看到有两种方法可以这样做。我可以在调试模式下运行airflow test命令，用于特定的进程和可选的任务。其他方法是使用DebugExecutor并运行特定的dag。我看到这两种方法都要求气流数据库已经启动并运行，并且所有池都配置好了(可能还需要队列)。我的问题是：
这两者之间的主要区别是什么？ airflow test在幕后使用DebugExecutor吗？是否有一种方法可以在不运行气流数据库和创建依赖的池和队列的情况下运行/调试达格和任务？<代码>G 211</code>
浏览 5提问于2020-11-29得票数 5
回答已采纳
2回答
我使用的是airflow开始日期：
from airflow.utils import dates
...
"start_date": dates.days_ago(3)
即将发布的是: 2020-11-14 00:00:00+00:00
我希望utc格式的日期为2020-11-14 00:00:00
我还想将时间增量(minutes=5)添加到2020-11-14 00:00:00
如何使用python(airflow)
浏览 1提问于2020-11-17得票数 0
假设我需要启用一个服务，然后启动该服务(例如某个web服务器)，我是否应该创建一个任务来启用该服务，然后创建另一个任务来启动该服务？或者我应该创建一个任务来启用服务，在这个服务中，创建一个通知，它触发一个处理程序来启动服务？
如果使用notify-handler的策略，那么问题是如果服务成功启用，但不知何故没有启动，那么稍后当我再次运行playbook时。由于该服务已启用，因此不会再启动它。
我认为把它们放在不同的任务中可能会更好？一般来说，人们是如何在Ansible中实现它们的？
如果单独编写任务，下面是我的代码：
tasks:
- name: enable airflow serv
浏览 2提问于2018-01-03得票数 2
回答已采纳
我不知道这是不是应该是这样的，但让我说，我做了一个4任务，我只把3个任务放在蒸汽中，为什么第四个任务也会出现和运行？
例：
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2018, 1, 1),
'email_on_failure': False,
'email_on_retry': False,
'retries
浏览 0提问于2020-02-06得票数 1
回答已采纳
我已经开始使用KubernetesExecutor，并使用AWS设置了一个PV/PVC来为我的dags存储日志。我还使用s3远程日志记录。
在一个守护程序完成后，所有的日志记录都非常正常。但是，我希望能够看到我的作业的日志，因为它们正在运行很长时间。
当我执行到调度程序pod中时，当执行器pod正在运行时，由于共享的EFS，我能够看到当前正在运行的作业的.log文件。但是，当我cat日志文件时，只要执行器仍在运行，我就不会看到日志。但是，执行程序完成后，我可以在cat文件和气流UI中看到完整的日志。
奇怪的是，在运行过程中，当我执行到executor pod中，并且在共享EFS中执行完全相同的
浏览 3提问于2021-01-28得票数 1
我的问题是：
我在用码头运行气流。当我在DAG中运行任务时，日志显示它被标记为成功，但也显示任务已退出，返回代码为1。
我试过的是：
我尝试增加分配给我的容器的内存量我从DAG中删除了关于失败逻辑的电子邮件
我的DAG
#
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regard
浏览 3提问于2021-07-07得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
