个人中心
文章发布
退出
作者热门文章
- html - 出于某种原因，IE8 对我的 Sass 文件中继承的 html5 CSS 不友好？
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景？
25
4
<分区>
在 Airflow 中，我正在编写一个包含多个任务的 DAG，到目前为止都是 PythonOperators。从 t1 我想在 xcom 字典中存储一个变量，然后在 t2 的函数中我想访问该变量而不显式调用任务名称(这需要在 t2 函数中对任务名称进行硬编码)。所以我的计划是访问 context['ti'] 并使用具有属性 task_id 的 _get_previous_ti()。这看起来像我想要的，但它绝对不适合我。
我试过这个:
from airflow.models import DAG, Variable
from airflow.utils.dates import days_ago
from airflow.operators.python_operator import PythonOperator
def task1(**context):
return 'TASK 1 RESULT'
def task2(**context):
previous_ti = context['ti']._get_previous_ti()
print("Previous TI: ", previous_ti)
previous_ti_id = previous_ti.task_id
print("Previous task_id: ", previous_ti_id)
# use previous_ti_id to access context['ti'].xcom.pull(previous_ti_id)
return
default_args = {
"owner": "me",
"start_date": days_ago(1)
}
dag = DAG(
dag_id='some_test',
default_args=default_args,
schedule_interval=None)
with dag:
t1 = PythonOperator(
task_id = "task_1_testing",
python_callable=task1,
provide_context=True)
t2 = PythonOperator(
task_id = "task_2_testing",
python_callable=task2,
provide_context=True)
t1 >> t2
但这会产生奇怪的结果:当我第一次测试它时，airflow 已经在运行并且它似乎正在引用先前触发的 dag 运行(？)的任务实例。当我退出 Airflow 并使用这段代码重新启动它时，它给了我错误的爆炸屏幕:AttributeError: 'NoneType' object has no attribute 'dag_id'。
我真正想要的是在 t2 函数中创建一个名为 previous_ti_id 的变量，在本例中它会返回等于 task_1_testing .可能吗？
我找到了 this previous question ，但我对 Airflow 的了解还不够，无法确定这是否相关(虽然看起来并不相关)。我将不胜感激。
25
4
0
我正在尝试做这样的事情:Name[i] = "Name"+ (i+1) 在 forloop 中，这样数组的值将是:Name[0] = Name1，Name[1] = Name2，Name[2] = N
我读了here，在GSP中我们可以这样写: ${params.action} 从GSP中，我们可以使用${params.action}作为参数调用Javascript函数(请参阅here)。 是否有其
我的问题:非常具体。我正在尝试想出解析以下文本的最简单方法: ^^domain=domain_value^^version=version_value^^account_type=account_ty
我创建了一条与此类似的路线: Router::connect("/backend/:controller/:action/*"); 现在我想将符合此模式的每个 Controller 路由重命名为类似
我在 Visual Studio 2013 项目中收到以下警告: SQL71502 - Procedure has an unresolved reference to object 最佳答案 这可以
任何人都可以指导我使用名称/值 .NET 集合或 .NET 名称/值字典以获得最佳性能吗？请问最好的方法是什么？我的应用程序是 ASP.NET、WCF/WF Web 应用程序。每个集合应该有 10 到
我在 Zend Framework 2 中有一个默认模块: namespace Application\Controller; use Zend\Mvc\Controller\AbstractActi
这是表格: 关于javascript - 在 javascript 中，这是一个有效的结构吗？ : document. 名称.名称.值？，我们在Stack Overflow上找到一个类似的
HtmlHelper.ActionLink(htmlhelper,string linktext,string action) 如何找出正确的路线？ 如果我有这个=> HtmlHelper.Actio
我需要一些有关如何将 Controller 定义传递给嵌套在 outer 指令中的 inner 指令的帮助。请参阅http://plnkr.co/edit/Om2vKdvEty9euGXJ5qan一个
请提出一个数据结构来表示内存中的记录列表。每条记录由以下部分组成: 用户名 积分 排名(基于积分)- 可选字段- 可以存储在记录中或可以动态计算 数据结构应该支持高效实现以下操作: Insert(re
错误 : 联合只能在具有兼容列类型的表上执行。 结构(层:字符串，skyward_number:字符串，skyward_points:字符串)<> 结构(skyward_number:字符串，层:字符
我想要一个包含可变数量函数的函数，但我希望在实际使用它们之前不要对它们求值。我可以使用 () => type 语法，但我更愿意使用 => type 语法，因为它似乎是为延迟评估而定制的。 当我尝试这样
我正在编写一个 elisp 函数，它将给定键永久绑定(bind)到当前主要模式的键盘映射中的给定命令。例如， (define-key python-mode-map [C-f1] 'pytho
卡在R中的错误上。 Error in names(x) <- value : 'names' attribute must be the same length as the ve
我有字符串，其中包含名称，有时在字符串中包含用户名，后跟日期时间戳: GN1RLWFH0546-2020-04-10-18-09-52-563945.txt JOHN-DOE-2020-04-10-1
有人知道为什么我会收到此错误吗？这显示将我的项目升级到新版本的Unity3d之后。 Error CS0103: The name `Array' does not exist in the curre
由于 Embarcadero 的 NNTP 服务器从昨天开始就停止响应，我想我可以在这里问:我使用非数据库感知网格，我需要循环遍历数据集以提取列数、它们的名称、数量行数以及每行中每个字段的值。 我知道
在构建Android应用程序的子项目中，我试图根据根build.gradle中的变量设置版本代码/名称。 子项目build.gradle: apply plugin: 'com.android.app
示例用例: 我有一个带有属性“myProperty”的对象，具有 getter 和 setter(自 EcmaScript 5 起支持“Property Getters 和 Setters”:http
我是一名优秀的程序员,十分优秀！