Skip to content
This repository has been archived by the owner on Dec 13, 2023. It is now read-only.
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: Netflix/conductor
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: v2.31.8
Choose a base ref
...
head repository: Netflix/conductor
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: 2.31
Choose a head ref
  • 1 commit
  • 1 file changed
  • 1 contributor

Commits on Jul 15, 2022

  1. Update start time in updateTask if it is unset (#3109)

    * Update start time in updateTask if it is unset
    
    Update start time in updateTask if it is unset.
    
    * Update ExecutionDAOFacade.java
    
    * Fix the import
    jun-he authored Jul 15, 2022
    Copy the full SHA
    816ef11 View commit details
Showing with 5 additions and 1 deletion.
  1. +5 −1 core/src/main/java/com/netflix/conductor/core/orchestration/ExecutionDAOFacade.java
Original file line number Diff line number Diff line change
@@ -12,6 +12,7 @@
*/
package com.netflix.conductor.core.orchestration;

import static com.netflix.conductor.common.metadata.tasks.Task.Status.IN_PROGRESS;
import static com.netflix.conductor.core.execution.WorkflowExecutor.DECIDER_QUEUE;

import com.fasterxml.jackson.core.JsonProcessingException;
@@ -361,7 +362,10 @@ public long getInProgressTaskCount(String taskDefName) {
*/
public void updateTask(Task task) {
try {
if (task.getStatus() != null) {
if (task.getStatus() != null) {
if (task.getStatus() == IN_PROGRESS && task.getStartTime() == 0) {
task.setStartTime(System.currentTimeMillis());
}
if (!task.getStatus().isTerminal() || (task.getStatus().isTerminal() && task.getUpdateTime() == 0)) {
task.setUpdateTime(System.currentTimeMillis());
}