dabla commented on code in PR #53009:
URL: https://github.com/apache/airflow/pull/53009#discussion_r2192610832
##########
providers/microsoft/azure/src/airflow/providers/microsoft/azure/operators/msgraph.py:
##########
@@ -108,8 +125,17 @@ class MSGraphAsyncOperator(BaseOperator):
the message from the event, otherwise the response from the event
payload is returned.
:param serializer: Class which handles response serialization (default is
ResponseSerializer).
Bytes will be base64 encoded into a string, so it can be stored as an
XCom.
+ :param start_from_trigger: If set to True, the operator will start
directly from the triggerer without going into the worker first.
"""
+ start_trigger_args = StartTriggerArgs(
+ trigger_cls=f"{MSGraphTrigger.__module__}.{MSGraphTrigger.__name__}",
+ trigger_kwargs={},
+ next_method="execute_complete",
+ next_kwargs=None,
+ timeout=None,
+ )
+ start_from_trigger = False
Review Comment:
I've refactored code to always run from triggerer and modified tests to
support this
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
