Skip to content

Navigation Menu

Explore
By company size
By use case
By industry
View all solutions
Topics
- AI
- DevOps
- Security
- Software Development
- View all
Explore
- GitHub Sponsors
  Fund open source developers
- The ReadME Project
  GitHub community articles
Repositories
- Enterprise platform
  AI-powered developer platform
Available add-ons
Pricing

Search code, repositories, users, issues, pull requests...

Search

Clear

Search syntax tips

Provide feedback

We read every piece of feedback, and take your input very seriously.

Include my email address so I can be contacted

Saved searches

Use saved searches to filter your results more quickly

Name

Query

To see all available qualifiers, see our documentation.

You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session.

Dismiss alert

epfml / disco Public

Notifications You must be signed in to change notification settings
Fork 27
Star 158

Code
Issues 55
Pull requests 12
Actions
Projects
Wiki
Security
Insights

Additional navigation options

Code
Issues
Pull requests
Actions
Projects
Wiki
Security
Insights

Allow decentralized users to join late and catch up#775

Merged

JulienVig merged 56 commits intodevelopepfml/disco:developfrom 718-decentralized-julienepfml/disco:718-decentralized-julienCopy head branch name to clipboard

Oct 14, 2024

+1,048-766

Conversation Commits56 (56)Checks Files changed

Commits

Commits on Oct 9, 2024

Rename Base to Aggregator and simplify event cycle
JulienVig
committed
Update aggregator test
JulienVig
committed
Clarify todo
JulienVig
committed
Simplify receiving a weight update
JulienVig
committed
Simplify log
JulienVig
committed
include aggregation round and communication round in decentralized messages
JulienVig
committed
Rename Training to TrainingSteps
JulienVig
committed
Update round status messages
JulienVig
committed
Add comment for non-awaited promised
JulienVig
committed
Extend discojs EventEmitter
JulienVig
committed
Handle async listener and running listener on past events
JulienVig
committed
update event emitter subscription
JulienVig
committed
Update decentralized payload message
JulienVig
committed
Fix import rename
JulienVig
committed
Fix linting error
JulienVig
committed
Update decentralized round status
JulienVig
committed
Put messages in common between federated and decentralized
JulienVig
committed
Move participant management logic to parent class
JulienVig
committed
Make peers wait when not enough participants
JulienVig
committed
Move participant waiting to parent class
JulienVig
committed
Replace private keywords by private fields
JulienVig
committed
Add a new JoinRound decentralized message
JulienVig
committed
Enable peers to join/leave mid session. Establish p2p connection in onRoundEndCommunication
JulienVig
committed
Rm unused decentralizedSecure parameter
JulienVig
committed
Specify aggregation strategy in default tasks
JulienVig
committed
rm commented code
JulienVig
committed
Add more FAQ troubleshooting
JulienVig
committed
Fix decentralized participant number
JulienVig
committed
Test client status
JulienVig
committed
discojs/src/aggregator/aggregator: clean code following @tharvik 's comments
JulienVig
committed
discojs/src/aggregator: rm unused methods
JulienVig
committed
discojs/src/aggregator/mean.spec: inline client names
JulienVig
committed
discojs/src/aggregator/mean.spec: move away from time-based tests
JulienVig
committed
discojs/src/aggregator: split add method into common public add and protected abstract _add
JulienVig
committed
discojs/src/client: change this.shortID method to shortenID function
JulienVig
committed
discojs/src/client: rename checkIfWaitForParticipants to waitForParticipantsIfNeeded
JulienVig
committed
discojs/src/client/decentralized/decentralized_client: get rid of roundParticipants and stop resetting the nodes list at the end of round
JulienVig
committed
discojs/src/client/decentralized/decentralized_client: send payloads with forEach instead of map
JulienVig
committed
discojs/client/decentralized_client: save and emit "connecting to peers" before waiting for participants if needed
JulienVig
committed
server/tests/e2e: rely on a Queue to test RoundStatus
JulienVig
committed
discojs/src/client|trainer: Make getNbOfParticipant parent method abstract to enforce subclass override
JulienVig
committed
discojs/src/default_tasks/mnist: make MNIST task use secure aggregation
JulienVig
committed
server/decentralized_controllers: rename checkThenSendPeersForRound to sendPeersForRoundIfNeeded
JulienVig
committed
server/federated_controller: use await instead of then
JulienVig
committed
server/decentralized_controller: invert condition to exit early
JulienVig
committed
server/controllers: create common sendWaitForMoreParticipantsMsg method
JulienVig
committed
server/controllers: clean checkIfEnoughParticipants and rename to sendEnoughParticipantsMsgIfNeeded
JulienVig
committed
server/src: rename TaskInitializer to TaskSet
JulienVig
committed
server/tests/e2e/decentralized.spec: avoid casting as RoundLogs
JulienVig
committed
*: renaming round statuses to lowercase
JulienVig
committed
webapp/Trainer.vue: convert roundStatus type from string to [RoundStatus, string]
JulienVig
committed
*: Provide initial tasks to the server when calling serve instead of the constructor and get rid of the static async server constructor
JulienVig
committed
*: remove past event subscription on EventEmitter (now that tasks are added after routers are initialized)
JulienVig
committed
*: make aggregator.add check if contribution is valid
JulienVig
committed
*: Make aggregator.add return void to enforce listening to the 'aggregation' event to get the aggregated weights
JulienVig
committed
*: enforce using override keyword
JulienVig
committed

Footer

© 2025 GitHub, Inc.

Footer navigation

Terms
Privacy
Security
Status
Docs
Contact

You can’t perform that action at this time.