pankajkoti commented on code in PR #32646:
URL: https://github.com/apache/airflow/pull/32646#discussion_r1275121766
##########
airflow/providers/redis/log/redis_task_handler.py:
##########
@@ -78,7 +78,7 @@ def _read(
).decode()
return log_str, {"end_of_log": True}
- def set_context(self, ti: TaskInstance):
+ def set_context(self, ti: TaskInstance, **kwargs) -> None:
Review Comment:
the support for identifier has not been added in providers yet(thought to
keep of the scope of this PR to just add the functionality to core). I added
the **kwargs for the time being to allow static checks to pass which were
failing earlier.
--
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]
