Skip to content
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

Removed kafka integration, replaced by webhooks #27

Merged
merged 21 commits into from
Nov 21, 2022
Merged

Conversation

quaxsze
Copy link
Contributor

@quaxsze quaxsze commented Oct 25, 2022

@quaxsze quaxsze changed the title Removed kafka integration, replaced by webhooks WIP: Removed kafka integration, replaced by webhooks Oct 25, 2022
@quaxsze quaxsze requested a review from maudetes October 25, 2022 15:41
@quaxsze
Copy link
Contributor Author

quaxsze commented Oct 25, 2022

Still work in progress but I'd like a first review @maudetes

Copy link
Contributor

@maudetes maudetes left a comment

Choose a reason for hiding this comment

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

A first batch of review.

But I think I had the same logic in mind :)

udata_hydra/utils/http.py Outdated Show resolved Hide resolved
udata_hydra/crawl.py Outdated Show resolved Hide resolved
Copy link
Contributor

@abulte abulte left a comment

Choose a reason for hiding this comment

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

I wonder if we need a Celery or RQ to handle http calls to udata. Using aiohttp instead of requests will make it "less blocking" but still.

We'll need one scheduler anyway when adding analysis. But maybe we can wait till then.

udata_hydra/utils/http.py Outdated Show resolved Hide resolved
@quaxsze quaxsze changed the title WIP: Removed kafka integration, replaced by webhooks Removed kafka integration, replaced by webhooks Nov 16, 2022
Copy link
Contributor

@maudetes maudetes left a comment

Choose a reason for hiding this comment

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

Some comments, notably on the relation with udata

udata_hydra/utils/http.py Outdated Show resolved Hide resolved
udata_hydra/utils/http.py Outdated Show resolved Hide resolved
udata_hydra/utils/http.py Show resolved Hide resolved
udata_hydra/datalake_service.py Outdated Show resolved Hide resolved
udata_hydra/crawl.py Outdated Show resolved Hide resolved
udata_hydra/datalake_service.py Outdated Show resolved Hide resolved
udata_hydra/datalake_service.py Outdated Show resolved Hide resolved
udata_hydra/utils/http.py Outdated Show resolved Hide resolved
udata_hydra/utils/http.py Outdated Show resolved Hide resolved
Copy link
Contributor

@maudetes maudetes left a comment

Choose a reason for hiding this comment

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

Oh yeah! let's merge! 🚀

udata_hydra/utils/http.py Show resolved Hide resolved
@quaxsze quaxsze merged commit fed48ab into main Nov 21, 2022
@quaxsze quaxsze deleted the Kafka-eventectomie branch November 21, 2022 17:36
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
3 participants