Skip to content

Commit

Permalink
Added original comments back
Browse files Browse the repository at this point in the history
  • Loading branch information
noryev committed Jun 17, 2024
1 parent 30ab180 commit 1520184
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion pkg/jobcreator/controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -249,7 +249,7 @@ func (controller *JobCreatorController) allowlistApproved() error {
controller.web3Events.Storage.SubscribeDealStateChange(func(ev storage.StorageDealStateChange) {
deal, err := controller.solverClient.GetDeal(ev.DealId)
if err != nil {
controller.log.Error("module allolist error", err)
controller.log.Error("module allowlist error", err)
return
}
if deal.JobCreator != controller.web3SDK.GetAddress().String() {
Expand Down Expand Up @@ -347,6 +347,10 @@ func (controller *JobCreatorController) agreeToDeals() error {
return nil
}

// list the deals that have results posted but we have not yet checked
// we do this synchronously to prevent us racing with large result sets
// also we are the client so have a lower chance of there being a chunky backlog

func (controller *JobCreatorController) checkResults() error {
// load all deals in ResultsSubmitted state and don't have either results checked or accepted txs
completedDeals, err := controller.solverClient.GetDealsWithFilter(
Expand Down

0 comments on commit 1520184

Please sign in to comment.