We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent dc6793b commit 7d57de1Copy full SHA for 7d57de1
1 file changed
devel-common/src/tests_common/test_utils/operators/run_deferrable.py
@@ -42,14 +42,14 @@ def run_trigger(trigger: BaseTrigger) -> list[TriggerEvent]:
42
43
def execute_operator(operator: Operator) -> tuple[Any, Any]:
44
context = mock_context(task=operator)
45
+ operator.render_template_fields(context=context)
46
return asyncio.run(deferrable_operator(context, operator))
47
48
49
async def deferrable_operator(context, operator):
50
result = None
51
triggered_events = []
52
try:
- operator.render_template_fields(context=context)
53
result = operator.execute(context=context)
54
except TaskDeferred as deferred:
55
task = deferred
0 commit comments