Skip to content

Conversation

@vlazuka
Copy link
Contributor

@vlazuka vlazuka commented May 2, 2023

This pull request fixes: #31027

@boring-cyborg
Copy link

boring-cyborg bot commented May 2, 2023

Congratulations on your first Pull Request and welcome to the Apache Airflow community! If you have any issues or are unsure about any anything please check our Contribution Guide (https://github.com/apache/airflow/blob/main/CONTRIBUTING.rst)
Here are some useful points:

  • Pay attention to the quality of your code (ruff, mypy and type annotations). Our pre-commits will help you with that.
  • In case of a new feature add useful documentation (in docstrings or in docs/ directory). Adding a new operator? Check this short guide Consider adding an example DAG that shows how users should use it.
  • Consider using Breeze environment for testing locally, it's a heavy docker but it ships with a working Airflow and a lot of integrations.
  • Be patient and persistent. It might take some time to get a review or get the final approval from Committers.
  • Please follow ASF Code of Conduct for all communication including (but not limited to) comments on Pull Requests, Mailing list and Slack.
  • Be sure to read the Airflow Coding style.
    Apache Airflow is a community-driven project and together we are making it better 🚀.
    In case of doubts contact the developers at:
    Mailing List: dev@airflow.apache.org
    Slack: https://s.apache.org/airflow-slack

@vlazuka
Copy link
Contributor Author

vlazuka commented May 2, 2023

Tagging @ephraimbuddy @pierrejeambrun @josh-fell

Copy link
Member

@jedcunningham jedcunningham left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

There are some other checks against redis:// in that same file. Can you do the same for the rest of them?

@vlazuka vlazuka requested review from jedcunningham and josh-fell May 3, 2023 09:22
@vlazuka vlazuka requested a review from uranusjr May 3, 2023 19:56
@uranusjr uranusjr changed the title Update default_celery.py to include rediss to the list of supported u… Include rediss to the list of supported URL schemes May 3, 2023
Copy link
Contributor Author

@vlazuka vlazuka left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

changes are added

@vlazuka
Copy link
Contributor Author

vlazuka commented May 5, 2023

Tagging @uranusjr @josh-fell @jedcunningham @rozza @hussein-awala @potiuk to make it reviewed faster

Copy link
Member

@pankajkoti pankajkoti left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Did you get a chance to test this E2E with both redis and rediss? If yes, will it possible to share some logs/screenshot of the working solution.

@vlazuka
Copy link
Contributor Author

vlazuka commented May 12, 2023

@pankajkoti

It was like this:
Screenshot 2023-05-12 at 12 07 45 PM

And the error went away:
Screenshot 2023-05-12 at 2 21 18 PM

Referring to this Issue I created before

Copy link
Member

@uranusjr uranusjr left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks fine as far as I can tell

Copy link
Member

@hussein-awala hussein-awala left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@hussein-awala
Copy link
Member

Can you install pre-commit to fix static checks (doc) and fix the failed tests?

@vlazuka
Copy link
Contributor Author

vlazuka commented May 25, 2023

It seems I can't merge without @jedcunningham because you requested changes and you need to review them know

@hussein-awala
Copy link
Member

Actually the PR is blocked by the failed CI, you need to fix the static checks as I explained before (doc)

Comment on lines 55 to 56
result_backend = f'db+{conf.get("database", "SQL_ALCHEMY_CONN")}'
result_backend = "db+{}".format(conf.get("database", "SQL_ALCHEMY_CONN"))
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why change this?

@vlazuka
Copy link
Contributor Author

vlazuka commented May 26, 2023

Hello @hussein-awala,

Thank you for pointing at this. CI allows to merge the pr though (hm).
Actually the failure is from the pr 30352 by @ORuteMa
Screenshot 2023-05-26 at 12 34 59 PM

TBH I don't understand why we create a new variable broker_transport_options_for_celery there

@uranusjr take a look, please

Thanks

@uranusjr
Copy link
Member

I added some changes, this should be enough to convince Mypy.

@ORuteMa
Copy link
Contributor

ORuteMa commented May 29, 2023

Hello @hussein-awala,

Thank you for pointing at this. CI allows to merge the pr though (hm). Actually the failure is from the pr 30352 by @ORuteMa Screenshot 2023-05-26 at 12 34 59 PM

TBH I don't understand why we create a new variable broker_transport_options_for_celery there

@uranusjr take a look, please

Thanks

Hello, it used in the situation that you have sentinel and redis server both password-authed.

@vlazuka
Copy link
Contributor Author

vlazuka commented Jun 7, 2023

When is this going to be merged and released?

@potiuk potiuk merged commit 471fdac into apache:main Jun 7, 2023
@boring-cyborg
Copy link

boring-cyborg bot commented Jun 7, 2023

Awesome work, congrats on your first merged pull request! You are invited to check our Issue Tracker for additional contributions.

@eladkal eladkal added this to the Airflow 2.6.2 milestone Jun 8, 2023
@eladkal eladkal added the type:bug-fix Changelog: Bug Fixes label Jun 8, 2023
eladkal pushed a commit that referenced this pull request Jun 8, 2023
---------

Co-authored-by: Tzu-ping Chung <uranusjr@gmail.com>
(cherry picked from commit 471fdac)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

type:bug-fix Changelog: Bug Fixes

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Airflow doesn't recognize rediss:... url to point to a Redis broker

9 participants