We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a45adfe commit a5570e2Copy full SHA for a5570e2
1 file changed
lib/cloud_controller/diego/tasks_sync.rb
@@ -78,8 +78,7 @@ def formatted_backtrace_from_error(error)
78
def update_missing_diego_tasks(to_update)
79
to_update.each do |task_guid|
80
workpool.submit(task_guid) do |guid|
81
- diego_task_missing = bbs_task_client.fetch_task(guid).nil?
82
- if diego_task_missing
+ if bbs_task_client.fetch_task(guid).nil?
83
# Mark the CC task as failed. Don't update tasks that are already in a terminal state.
84
task = TaskModel.where(guid:).exclude(state: [TaskModel::FAILED_STATE, TaskModel::SUCCEEDED_STATE]).first
85
task&.update(state: TaskModel::FAILED_STATE, failure_reason: BULKER_TASK_FAILURE) # invoke model's update method to create an event
0 commit comments