Skip to content
This repository has been archived by the owner on May 12, 2021. It is now read-only.

Commit

Permalink
- remove unused methods and cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
chrismattmann committed Aug 5, 2018
1 parent 35f9f91 commit 2620d43
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 32 deletions.
12 changes: 0 additions & 12 deletions proteus/src/main/java/backend/ProcessDratWrapper.java
Expand Up @@ -363,18 +363,6 @@ protected boolean taskStillRunning(List<WorkflowInstance> instances, String ...t
return false;
}

@VisibleForTesting
@Deprecated
protected List<WorkflowInstance> filterPartitioners(List<WorkflowInstance> instances){
return filterInstances(instances, PARTITION_AND_MAP_TASK_ID);
}

@VisibleForTesting
@Deprecated
protected List<WorkflowInstance> filterMappers(List<WorkflowInstance> instances){
return this.filterInstances(instances, MAPPER_TASK_ID);
}

@VisibleForTesting
protected List<WorkflowInstance> filterInstances(List<WorkflowInstance> instances, String taskId){
List<WorkflowInstance> insts = new ArrayList<>();
Expand Down
20 changes: 0 additions & 20 deletions proteus/src/test/java/backend/TestProcessDratWrapper.java
Expand Up @@ -76,26 +76,6 @@ public void testFilterPartitioners(){
assertNotNull(partitioners);
assertEquals(2, partitioners.size());
}

public void testFilterPartitioners(){
ProcessDratWrapper wrapper = ProcessDratWrapper.getInstance();
assertNotNull(wrapper);
String cmdLines = "Instance: [id=d3aed64f-6e7c-11e7-af03-cb83c51de744, status=FINISHED, currentTask=urn:drat:MimePartitioner, workflow=Dynamic Workflow-6fc5fc4c-d27a-47f6-905c-2f2e99fa92e9,wallClockTime=0.13265,currentTaskWallClockTime=0.0]\n" +
"Instance: [id=d3aed64f-6e7c-11e7-af03-cb83c51de744, status=PGE EXEC, currentTask=urn:drat:MimePartitioner, workflow=Dynamic Workflow-6fc5fc4c-d27a-47f6-905c-2f2e99fa92e9,wallClockTime=0.13265,currentTaskWallClockTime=0.0]\n" +
"Instance: [id=d3aed64f-6e7c-11e7-af03-cb83c51de744, status=PGE EXEC, currentTask=urn:drat:RatCodeAudit, workflow=Dynamic Workflow-6fc5fc4c-d27a-47f6-905c-2f2e99fa92e9,wallClockTime=0.13265,currentTaskWallClockTime=0.0]";

List<WorkflowItem> items = null;
items = wrapper.parseWorkflows(cmdLines);
assertNotNull(items);
List<WorkflowInstance> insts = new ArrayList<WorkflowInstance>(items.size());
for(WorkflowItem wi: items) {
insts.add(wi.toInstance());
}
List<WorkflowInstance> partitioners = null;
partitioners = wrapper.filterPartitioners(insts);
assertNotNull(partitioners);
assertEquals(2, partitioners.size());
}

public void testFilterMappers(){
ProcessDratWrapper wrapper = ProcessDratWrapper.getInstance();
Expand Down

0 comments on commit 2620d43

Please sign in to comment.