| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279 |
- /*
- Licensed to Cloudera, Inc. under one
- or more contributor license agreements. See the NOTICE file
- distributed with this work for additional information
- regarding copyright ownership. Cloudera, Inc. licenses this file
- to you under the Apache License, Version 2.0 (the
- "License"); you may not use this file except in compliance
- with the License. You may obtain a copy of the License at
- http://www.apache.org/licenses/LICENSE-2.0
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
- */
- function getFileBrowseButton() {}
- describe("WorkflowModel", function(){
- function create_three_step_workflow(workflow_id) {
- var workflow_model = new WorkflowModel({
- "id": workflow_id,
- "name": "Test-Three-Step-Workflow",
- "start": 1,
- "end": 5,
- "nodes":[{
- "description":"",
- "workflow":workflow_id,
- "child_links":[{
- "comment":"",
- "name":"to",
- "parent":1,
- "child":2
- },{
- "comment":"",
- "name":"related",
- "parent":1,
- "child":5
- }],
- "node_type":"start",
- "id":1,
- "name":"start"
- },{
- "id":2,
- "name":"Sleep-1",
- "workflow":workflow_id,
- "node_type":"mapreduce",
- "jar_path":"/user/hue/oozie/workspaces/lib/hadoop-examples.jar",
- "child_links":[{
- "comment":"",
- "name":"ok",
- "parent":2,
- "child":3
- },{
- "comment":"",
- "name":"error",
- "parent":2,
- "child":6
- }],
- },{
- "id":3,
- "name":"Sleep-2",
- "workflow":workflow_id,
- "node_type":"mapreduce",
- "jar_path":"/user/hue/oozie/workspaces/lib/hadoop-examples.jar",
- "child_links":[{
- "comment":"",
- "name":"ok",
- "parent":3,
- "child":4
- },{
- "comment":"",
- "name":"error",
- "parent":3,
- "child":6
- }],
- },{
- "id":4,
- "name":"Sleep-3",
- "workflow":workflow_id,
- "node_type":"mapreduce",
- "jar_path":"/user/hue/oozie/workspaces/lib/hadoop-examples.jar",
- "child_links":[{
- "comment":"",
- "name":"ok",
- "parent":4,
- "child":5
- },{
- "comment":"",
- "name":"error",
- "parent":4,
- "child":6
- }],
- },{
- "id":6,
- "name":"kill",
- "workflow":workflow_id,
- "node_type":"kill",
- "child_links":[],
- "message":"Action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]",
- },{
- "id":5,
- "name":"end",
- "workflow":workflow_id,
- "node_type":"end",
- "child_links":[],
- }],
- });
- var registry = new Registry();
- var workflow = new Workflow({
- model: workflow_model,
- registry: registry
- });
- return workflow;
- }
- function create_pig_workflow(workflow_id) {
- var workflow_model = new WorkflowModel({
- "id": workflow_id,
- "name": "Test-pig-Workflow",
- "start": 1,
- "end": 5,
- "nodes":[{
- "description":"",
- "workflow":workflow_id,
- "child_links":[{
- "comment":"",
- "name":"to",
- "parent":1,
- "child":2
- },{
- "comment":"",
- "name":"related",
- "parent":1,
- "child":5
- }],
- "node_type":"start",
- "id":1,
- "name":"start"
- },{
- "id":2,
- "name":"Pig-1",
- "workflow":workflow_id,
- "node_type":"pig",
- "script_path":"test.pig",
- "child_links":[{
- "comment":"",
- "name":"ok",
- "parent":2,
- "child":3
- },{
- "comment":"",
- "name":"error",
- "parent":2,
- "child":4
- }],
- },{
- "id":4,
- "name":"kill",
- "workflow":workflow_id,
- "node_type":"kill",
- "child_links":[],
- "message":"Action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]",
- },{
- "id":3,
- "name":"end",
- "workflow":workflow_id,
- "node_type":"end",
- "child_links":[],
- }],
- })
- var registry = new Registry();
- var workflow = new Workflow({
- model: workflow_model,
- registry: registry
- });
- return workflow;
- }
- describe("Workflow operations", function(){
- var json = '{"id":1,"name":"Test-pig-Workflow","start":1,"end":5,"nodes":[{"description":"","workflow":1,"child_links":[{"comment":"","name":"to","parent":1,"child":2},{"comment":"","name":"related","parent":1,"child":5}],"node_type":"start","id":1,"name":"start"},{"id":2,"name":"Pig-1","workflow":1,"node_type":"pig","script_path":"test.pig","child_links":[{"comment":"","name":"ok","parent":2,"child":3},{"comment":"","name":"error","parent":2,"child":4}],"description":"","files":"[]","archives":"[]","job_properties":"[]","prepares":"[]","job_xml":"","params":"[]"},{"id":3,"name":"end","workflow":1,"node_type":"end","child_links":[],"description":""},{"id":4,"name":"kill","workflow":1,"node_type":"kill","child_links":[],"message":"Action failed, error message[${wf:errorMessage(wf:lastErrorNode())}]","description":""}],"parameters":[],"description":"","schema_version":0.4,"deployment_dir":"","is_shared":true,"job_xml":""}';
- var node = null;
- var viewModel = create_pig_workflow(1);
- viewModel.rebuild();
- it("Ensure serialized data sent to server is proper", function() {
- expect(viewModel.toJSON()).toEqual(ko.toJSON($.parseJSON(json)));
- });
- it("Ensure data received from server can be loaded", function() {
- viewModel.reload($.parseJSON(json.replace('test.pig','test1.pig')));
- expect(viewModel.id()).toEqual(1);
- expect(viewModel.name()).toEqual('Test-pig-Workflow');
- expect(viewModel.start()).toEqual(1);
- expect(viewModel.description()).toEqual("");
- expect(viewModel.schema_version()).toEqual(0.4);
- expect(viewModel.deployment_dir()).toEqual("");
- expect(viewModel.is_shared()).toEqual(true);
- expect(viewModel.parameters().length).toEqual(0);
- expect(viewModel.job_xml()).toEqual("");
- expect(viewModel.nodes().length).toEqual(3);
- expect(viewModel.nodes()[1].script_path()).toEqual('test1.pig');
- });
- });
- describe("Node APIs", function(){
- var node = null;
- var viewModel = create_three_step_workflow(2);
- viewModel.rebuild();
- it("Should be able to detach a node", function() {
- node = viewModel.nodes()[2];
- node.detach();
- viewModel.rebuild();
- expect(viewModel.nodes().length).toEqual(4);
- });
- it("Should be able to append a node", function() {
- viewModel.nodes()[1].append(node);
- viewModel.rebuild();
- expect(viewModel.nodes().length).toEqual(5);
- });
- it("Should be able to fail when appending the same node", function() {
- viewModel.nodes()[1].append(node);
- viewModel.rebuild();
- expect(viewModel.nodes().length).toEqual(5);
- });
- it("Should be able to add error node", function() {
- viewModel.nodes()[1].putErrorChild(viewModel.nodes()[2]);
- viewModel.rebuild();
- expect(viewModel.nodes().length).toEqual(5);
- expect(viewModel.nodes()[1].meta_links().length).toEqual(1);
- expect(viewModel.nodes()[1].meta_links()[0].name()).toEqual("error");
- expect(viewModel.nodes()[1].meta_links()[0].parent()).toEqual(viewModel.nodes()[1].id());
- expect(viewModel.nodes()[1].meta_links()[0].child()).toEqual(viewModel.nodes()[2].id());
- });
- it("Should be able to get error node", function() {
- viewModel.nodes()[1].putErrorChild(viewModel.nodes()[2]);
- viewModel.rebuild();
- expect(viewModel.nodes().length).toEqual(5);
- expect(viewModel.nodes()[1].getErrorChild().id()).toEqual(viewModel.nodes()[2].id());
- });
- });
- describe("Workflow node modal", function(){
- var node = null;
- var viewModel = create_three_step_workflow(2);
- var modal = new Modal($('#node-modal'));
- viewModel.rebuild();
- it("Ensure can open and close modal", function() {
- edit_node_modal(modal, viewModel, viewModel.nodes()[1]);
- expect(modal.el.is(":visible"));
- $('.doneButton').click();
- expect(!modal.el.is(":visible"));
- edit_node_modal(modal, viewModel, viewModel.nodes()[1]);
- expect(modal.el.is(":visible"));
- $('.cancelButton').click();
- expect(!modal.el.is(":visible"));
- });
- it("Ensure can change kill node of existing node", function() {
- edit_node_modal(modal, viewModel, viewModel.nodes()[1]);
- modal.context().error_node(viewModel.nodes()[0].id());
- expect(viewModel.nodes()[1].getErrorChild().id()).toEqual(viewModel.nodes()[0].id());
- $('.done').click();
- expect(viewModel.nodes()[1].getErrorChild().id()).toEqual(viewModel.nodes()[0].id());
- });
- });
- });
|