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

feat(meta): add support for sending notifications asynchronously #2029

Merged
merged 1 commit into from
Apr 22, 2022

Conversation

HuaHuaY
Copy link
Contributor

@HuaHuaY HuaHuaY commented Apr 21, 2022

What's changed and what's your intention?

Add support for sending notifications asynchronously.
It is used where it is only necessary to ensure that the message will be sent, but not that the message must be sent successfully at the end of the method.

Checklist

  • I have written necessary docs and comments
  • I have added necessary unit tests and integration tests

Refer to a related PR or issue link (optional)

}
};
if let Some(tx) = task.callback_tx {
tx.send(version).unwrap();
Copy link
Member

Choose a reason for hiding this comment

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

Suggest warning here or it may panic on meta exiting.

Suggested change
tx.send(version).unwrap();
if tx.send(version).is_err() {
warn!(...);
}

Copy link
Contributor Author

@HuaHuaY HuaHuaY Apr 22, 2022

Choose a reason for hiding this comment

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

I think we can change this after ci error happens.

@codecov
Copy link

codecov bot commented Apr 21, 2022

Codecov Report

Merging #2029 (d68a909) into main (28cf760) will decrease coverage by 0.12%.
The diff coverage is 62.63%.

@@            Coverage Diff             @@
##             main    #2029      +/-   ##
==========================================
- Coverage   70.79%   70.67%   -0.13%     
==========================================
  Files         628      629       +1     
  Lines       80785    81015     +230     
==========================================
+ Hits        57193    57257      +64     
- Misses      23592    23758     +166     
Flag Coverage Δ
rust 70.67% <62.63%> (-0.13%) ⬇️

Flags with carried forward coverage won't be shown. Click here to find out more.

Impacted Files Coverage Δ
src/meta/src/manager/catalog.rs 0.00% <0.00%> (ø)
src/meta/src/manager/catalog_v2.rs 20.00% <14.28%> (+0.37%) ⬆️
src/meta/src/manager/notification.rs 46.24% <75.75%> (+16.64%) ⬆️
src/meta/src/cluster/mod.rs 56.90% <100.00%> (+0.62%) ⬆️
src/meta/src/hummock/hummock_manager.rs 91.34% <100.00%> (+0.10%) ⬆️
src/frontend/src/handler/mod.rs 39.28% <0.00%> (-20.18%) ⬇️
src/meta/src/stream/scheduler.rs 83.41% <0.00%> (-13.80%) ⬇️
src/common/src/error.rs 70.85% <0.00%> (-0.88%) ⬇️
...ontend/src/optimizer/plan_node/stream_hash_join.rs 60.00% <0.00%> (-0.61%) ⬇️
src/connector/src/filesystem/file_common.rs 80.44% <0.00%> (-0.45%) ⬇️
... and 27 more

📣 Codecov can now indicate which changes are the most critical in Pull Requests. Learn more

@HuaHuaY HuaHuaY merged commit 98af87e into main Apr 22, 2022
@HuaHuaY HuaHuaY deleted the zehua/asynchronous_notification_manager branch April 22, 2022 06:17
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

3 participants