4

我有一个在节点上运行的 firebase-worker ( https://github.com/firebase/firebase-queue )。我有一个工作人员需要执行的特定任务的大量积压,但通常任务失败,然后工作人员只是停止并显示以下错误消息:

Oct 13 20:34:57 Worker app/low_priority_worker.1:  FIREBASE WARNING: transaction at /low_priority_queue/tasks/-KTupoITHgT10u5uasQq failed: disconnect
Oct 13 20:34:57 Worker app/low_priority_worker.1:  FIREBASE WARNING: transaction at /user_dashboard/-JmteP57yEdeDFzAyv-p/1476403200000/views/-KTuI5464YGfBx9KEmNs failed: disconnect

工作人员正在执行的任务是在 Firebase 路径上增加一个值:

# Increment comment amount on listing
incrementDashboardListingTypeAmountPromise = BaseHelper.firebaseDatabase.ref("user_dashboard").child(@data.seller_id).child("#{Date.create().setUTC(true).beginningOfDay().format("{x}")}").child(@data.type).child(@data.listing_id).transaction (currentValue) ->
  (currentValue || 0) + 1

# Promise callback
Promise.all([incrementDashboardListingTypeAmountPromise].compact()).then (results) =>
  # Execute callback
  callback()

在最后一个“callback()”上,任务得到解决并继续下一个任务。我在这里做错了吗?我错过了一些错误处理吗?

4

0 回答 0