-
Notifications
You must be signed in to change notification settings - Fork 14.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add use_glob to GCSObjectExistenceSensor #34137
Conversation
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)
|
0282862
to
df3878c
Compare
Can you please add unit tests for it? |
Sure, that was just an initial draft. I will try to push a complete version of this PR by the end of the day |
ed5c784
to
8f00241
Compare
if object_response: | ||
return "success" | ||
if self.use_glob: | ||
object_response = await bucket.list_blobs(match_glob=object_name) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this depends on talkiq/gcloud-aio#634
d268c78
to
9c1ac7b
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Overall LGTM :)
I hope that gcloud-aio
will merge your PR there soon, so you can also merge it here.
Don't forget to add a test for GCSBlobTrigger
Needs fixes though. |
talkiq/gcloud-aio#634 was merged today so this can be fixed and merged. Apart from the missing tests, what else needs to be fixed? @potiuk |
I think that is all but we will take closer look in 2nd review once everything is ready |
This pull request has been automatically marked as stale because it has not had recent activity. It will be closed in 5 days if no further activity occurs. Thank you for your contributions. |
any update on this? |
Well. The PR is waiting for your actions:
Tests are failed and @eladkal asked you to update libraries. Why do you think you need any update before following these comments ? |
Generallly - making PR green is a prerequisite for anyone to take further look - if tests are failing and you were told to fix them and nothing happened, well, then the ball is on your side. |
(plus you have still WIP in name - usualy that is an indication that this is Work In Progress - I usually just skip over such PRs even if they are rebased by author, because they are well, Work in Progress |
Here i asked if something else needed fix
Here a 2nd review was mentioned that never arrived.
this was your only message so far, not very helpful to a new contributor. Will work on the things you pointed out now though... |
Happy to review when you mark the PR as ready :) |
Well. The CI tells you what needs to be fixed. I think you should take a look at the contributor's guide and understand that fixing and rebasing CI is what is the "first pass". You have one PR to submit. We regularly review 100s of PR a day. And CI and tests are the way to automate thing that must be fixed before we do next pass of reviews. So my comment - while it had been expressed with brevity - reflect the state -of matter. you need to fix tests before we move any furtther. In case it is not clear - it's all described in our contributor's guide:
I understand it's a lot of information to digest, so I perfectly understand your lack of understanding how our PR process looks like and what is expected from author, but now that you got it explained in a little more than "tests need fixing" I hope you will continue contributing and follow those guidelines. I think also what helps is understand that it's you who want to contribute something to the project, so it's a good idea to pay attention to your own PR and if in doubt consult the documentation. Looking forward to your future contributions. No hard feelings from my side, I hope with those explanations you will understand why the ball was on your side all the time, you just did not follow up. |
@potiuk of course no hard feelings on my side either! I appreciate the exchange and I'm sorry if I came up as rude, was never the intention! Now that is more clear what is expected, and that action is required on my side, I'll be working on the things that are missing! Thanks |
Apologies if MY comments were also seen as condescent (which I realise they might) - but this is simply coming from the sheer volume of things we have to deal with - it's very difficult to balance brevity (not helpful) with long messages (TLDR) and the time it needs to put, so we rely a lot on the docs we put together on contributing, but - yeah - it's difficult to follow, I understand that. |
d3419c4
to
41feec9
Compare
I've added the missing test for GCSBlobTrigger and removed WIP from the title, as this is ready to be reviewed.
@eladkal regarding this, it seems to me that the version is not pinned in the yaml, so it should be fine already:
|
4688082
to
9837644
Compare
9837644
to
024f923
Compare
Is there a minimum version of gcloud-aio needed for that ? if so we should set >= MIN |
Yes, the I'll add the minimum version |
Awesome work, congrats on your first merged pull request! You are invited to check our Issue Tracker for additional contributions. |
Initial draft implementing #32650
Add the boolean parameter
use_glob
toGCSObjectExistenceSensor
.When set to
True
the sensor will use thehook.list
method leveraging the newly introducedmatch_glob
parameter to check if files are present, making it possible to define aGCSObjectExistenceSensor
that checks if files that satisfy the given glob are present in a certain bucket.^ Add meaningful description above
Read the Pull Request Guidelines for more information.
In case of fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
In case of a new dependency, check compliance with the ASF 3rd Party License Policy.
In case of backwards incompatible changes please leave a note in a newsfragment file, named
{pr_number}.significant.rst
or{issue_number}.significant.rst
, in newsfragments.