|
@@ -714,7 +714,7 @@ export default class Dag extends React.Component<any, any> {
|
|
|
const keys = Object.keys(data.data.nodes);
|
|
|
keys.forEach(item => {
|
|
|
if (data.data.nodes[item] === 'success') successIds.push(item);
|
|
|
- if (data.data.nodes[item] === 'falied') failedIds.push(item);
|
|
|
+ if (data.data.nodes[item] === 'failed') failedIds.push(item);
|
|
|
});
|
|
|
const allNodes = this.state.dagGraph.getNodes();
|
|
|
allNodes.forEach((item: any) => {
|
|
@@ -824,13 +824,15 @@ export default class Dag extends React.Component<any, any> {
|
|
|
const target = edge.getTargetNode().getData();
|
|
|
const source = edge.getSourceNode().getData();
|
|
|
if (source.nodeId === nodeId && target.type !== 'outputsource') {
|
|
|
- edge.getSourceNode().setData(
|
|
|
- {
|
|
|
- ...source,
|
|
|
- status: 'undone'
|
|
|
- },
|
|
|
- { overwrite: true }
|
|
|
- );
|
|
|
+ if (source.type !== 'datasource') {
|
|
|
+ edge.getSourceNode().setData(
|
|
|
+ {
|
|
|
+ ...source,
|
|
|
+ status: 'undone'
|
|
|
+ },
|
|
|
+ { overwrite: true }
|
|
|
+ );
|
|
|
+ }
|
|
|
edge.getTargetNode().setData(
|
|
|
{
|
|
|
...target,
|