650 anonymisation reads from queue - #663
Conversation
…aming of queue objects
Codecov Report❌ Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #663 +/- ##
==========================================
+ Coverage 88.41% 89.30% +0.88%
==========================================
Files 81 81
Lines 3972 4066 +94
==========================================
+ Hits 3512 3631 +119
+ Misses 460 435 -25 ☔ View full report in Codecov by Harness. 🚀 New features to boost your workflow:
|
stefpiatek
left a comment
There was a problem hiding this comment.
Ah nice, thanks Ruaridh, appreciate cracking this out. Some structural changes and then happy to a more fine-grained review
|
@p-j-smith |
607eedb to
e97ae06
Compare
p-j-smith
left a comment
There was a problem hiding this comment.
looking good. There's also the question of whether we want to make the new queue async, but for a future PR?
Yeah a future PR would be good, I think it would be easier to switch from sync to async later on as more could be combined but having the structure for sync is maybe useful to include for now |
stefpiatek
left a comment
There was a problem hiding this comment.
Thanks Ruaridh, looking good to me. A couple of questions and a suggestion for documentation
I don't think we do want this, because the de-id is an intensive process we'd probably want to spawn child processes to handle it so we're not bound by the same process |
ah yeah, good point, we want to keep the threading then |
p-j-smith
left a comment
There was a problem hiding this comment.
We'll need to make sure we wait for de-identification to finish before we ack the message. To avoid blocking the thread, we could switch to an async consumer and use asyncios run_in_executor to submit the work to our threadpool. Unless there's a better way @stefpiatek?
…ack until process finished
Description
Fixes PIX-68
Fixes #650: Adds new queue "anonymisation" in
pixl_core/anon_queuewithout async functionality, withinorthancadds anon_queue (to replace POST call which hasn't been removed yet), adds "anonymisation" to queue_to_count within thecliand adds corresponding tests withincliandpixl_core.Type of change
Please delete options accordingly to the description.
Suggested Checklist
mainbranch.squash and merge