Skip to content
This repository was archived by the owner on Oct 7, 2025. It is now read-only.

Conversation

rpiaggio
Copy link
Contributor

@rpiaggio rpiaggio commented Oct 7, 2025

No description provided.

@mergify mergify bot added the server_new label Oct 7, 2025
Comment on lines +81 to +91
val used: Set[Resource | Instrument] = ObserveEngine.resourcesInUse(st)

// Resources that will be used by sequences in running queues
val reservedByQueues = ObserveEngine.resourcesReserved(st)
val reservedByQueues: Set[Resource | Instrument] = ObserveEngine.resourcesReserved(st)

st.sequences
.get(obsId)
.exists(x =>
x.seqGen.resources.intersect(used).isEmpty && (
.exists(seqData =>
seqData.seqGen.resources.intersect(used).isEmpty && (
st.queues.values.filter(_.status.running).exists(_.queue.contains(obsId)) ||
x.seqGen.resources.intersect(reservedByQueues).isEmpty
seqData.seqGen.resources.intersect(reservedByQueues).isEmpty
Copy link
Contributor Author

Choose a reason for hiding this comment

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

No logic changed here. Just adding types and more explicit names.

Copy link
Contributor

@jluhrs jluhrs left a comment

Choose a reason for hiding this comment

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

LGTM

@rpiaggio rpiaggio merged commit 184f54a into main Oct 7, 2025
10 checks passed
@rpiaggio rpiaggio deleted the error-if-busy branch October 7, 2025 19:46
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants