Skip to content

Commit

Permalink
Merge hasQueuedDttm and validQueuedDttm.
Browse files Browse the repository at this point in the history
  • Loading branch information
tirkarthi committed Dec 4, 2023
1 parent b20d18d commit 2578d02
Showing 1 changed file with 10 additions and 9 deletions.
19 changes: 10 additions & 9 deletions airflow/www/static/js/dag/details/gantt/Row.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -52,20 +52,19 @@ const Row = ({

const instance = task.instances.find((ti) => ti.runId === runId);
const isSelected = taskId === instance?.taskId;
const hasQueuedDttm = !!instance?.queuedDttm;
const validQueuedDttm =
hasQueuedDttm &&
const hasValidQueuedDttm =
!!instance?.queuedDttm &&
(instance?.startDate && instance?.queuedDttm
? instance.queuedDttm < instance.startDate
: true);
const isOpen = openGroupIds.includes(task.id || "");

// Calculate durations in ms
const taskDuration = getDuration(instance?.startDate, instance?.endDate);
const queuedDuration = validQueuedDttm
const queuedDuration = hasValidQueuedDttm
? getDuration(instance?.queuedDttm, instance?.startDate)
: 0;
const taskStartOffset = validQueuedDttm
const taskStartOffset = hasValidQueuedDttm
? getDuration(ganttStartDate, instance?.queuedDttm || instance?.startDate)
: getDuration(ganttStartDate, instance?.startDate);

Expand All @@ -78,8 +77,8 @@ const Row = ({
// Min width should be 5px
let width = ganttWidth * taskDurationPercent;
if (width < 5) width = 5;
let queuedWidth = validQueuedDttm ? ganttWidth * queuedDurationPercent : 0;
if (validQueuedDttm && queuedWidth < 5) queuedWidth = 5;
let queuedWidth = hasValidQueuedDttm ? ganttWidth * queuedDurationPercent : 0;
if (hasValidQueuedDttm && queuedWidth < 5) queuedWidth = 5;
const offsetMargin = taskStartOffsetPercent * ganttWidth;

return (
Expand Down Expand Up @@ -110,7 +109,7 @@ const Row = ({
});
}}
>
{instance.state !== "queued" && hasQueuedDttm && (
{instance.state !== "queued" && hasValidQueuedDttm && (
<SimpleStatus
state="queued"
width={`${queuedWidth}px`}
Expand All @@ -123,7 +122,9 @@ const Row = ({
state={instance.state}
width={`${width}px`}
borderLeftRadius={
instance.state !== "queued" && hasQueuedDttm ? 0 : undefined
instance.state !== "queued" && hasValidQueuedDttm
? 0
: undefined
}
/>
</Flex>
Expand Down

0 comments on commit 2578d02

Please sign in to comment.