Loading Cargo.lock +3 −3 Original line number Diff line number Diff line # This file is automatically @generated by Cargo. # It is not intended for manual editing. version = 3 version = 4 [[package]] name = "addr2line" Loading Loading @@ -2235,7 +2235,7 @@ checksum = "8b870d8c151b6f2fb93e84a13146138f05d02ed11c7e7c54f8826aaaf7c9f184" [[package]] name = "pipe-cli" version = "0.0.6" version = "0.0.7" dependencies = [ "assert_cmd", "cargo-watch", Loading @@ -2261,7 +2261,7 @@ dependencies = [ [[package]] name = "pipe-lib" version = "0.0.6" version = "0.0.7" dependencies = [ "bon", "bytes", Loading Cargo.toml +1 −1 Original line number Diff line number Diff line Loading @@ -3,7 +3,7 @@ members = ["pipe-cli", "pipe-lib"] resolver = "2" [workspace.package] version = "0.0.6" version = "0.0.7" authors = ["Jason Wohlgemuth <wohlgemuthjh@ornl.gov>"] description = "Parallel Integration and Processing Engine" documentation = "https://pipe.ornl.gov" Loading lcov.info +170 −167 Original line number Diff line number Diff line Loading @@ -271,18 +271,18 @@ end_of_record TN: SF:/root/dev/command/pipe-lib/src/config.rs FN:119,Config::get_environment_variables FN:131,Config::get_inputs FN:161,Config::get_module_list FN:176,Config::prepare_modules FN:400,Config::read FN:424,Config::read_json FN:445,Config::read_yaml FN:465,Config::run_workflow FN:555,Config::set_environment_variables FN:573,Config::verify_requirements FN:593,Config::verify_resources FN:596,Config::with_options FN:602,Extension::from_string FN:139,Config::get_inputs FN:169,Config::get_module_list FN:184,Config::prepare_modules FN:408,Config::read FN:432,Config::read_json FN:453,Config::read_yaml FN:473,Config::run_workflow FN:563,Config::set_environment_variables FN:581,Config::verify_requirements FN:601,Config::verify_resources FN:604,Config::with_options FN:610,Extension::from_string FNF:13 FNDA:0,Config::get_environment_variables FNDA:1,Config::get_inputs Loading @@ -302,258 +302,261 @@ DA:120,0 DA:121,0 DA:122,0 DA:123,0 DA:124,0 DA:125,0 DA:131,1 DA:132,1 DA:133,1 DA:134,1 DA:135,2 DA:136,2 DA:138,3 DA:139,2 DA:129,0 DA:130,0 DA:131,0 DA:132,0 DA:133,0 DA:139,1 DA:140,1 DA:142,0 DA:143,0 DA:147,0 DA:148,0 DA:152,1 DA:153,0 DA:158,0 DA:161,1 DA:162,2 DA:165,2 DA:167,2 DA:176,0 DA:177,0 DA:178,0 DA:180,0 DA:181,0 DA:141,1 DA:142,1 DA:143,2 DA:144,2 DA:146,3 DA:147,2 DA:148,1 DA:150,0 DA:151,0 DA:155,0 DA:156,0 DA:160,1 DA:161,0 DA:166,0 DA:169,1 DA:170,2 DA:173,2 DA:175,2 DA:184,0 DA:185,0 DA:186,0 DA:188,0 DA:189,0 DA:190,0 DA:191,0 DA:192,0 DA:193,0 DA:194,0 DA:196,0 DA:197,0 DA:198,0 DA:199,0 DA:200,0 DA:201,0 DA:202,0 DA:203,0 DA:204,0 DA:205,0 DA:206,0 DA:207,0 DA:208,0 DA:209,0 DA:210,0 DA:211,0 DA:212,0 DA:214,0 DA:213,0 DA:215,0 DA:216,0 DA:217,0 DA:218,0 DA:219,0 DA:221,0 DA:226,0 DA:232,0 DA:220,0 DA:222,0 DA:227,0 DA:229,0 DA:234,0 DA:237,0 DA:240,0 DA:242,0 DA:244,0 DA:248,0 DA:251,0 DA:254,0 DA:245,0 DA:250,0 DA:252,0 DA:256,0 DA:258,0 DA:259,0 DA:260,0 DA:261,0 DA:263,0 DA:262,0 DA:264,0 DA:266,0 DA:267,0 DA:268,0 DA:269,0 DA:270,0 DA:273,0 DA:275,0 DA:271,0 DA:272,0 DA:276,0 DA:277,0 DA:279,0 DA:280,0 DA:278,0 DA:281,0 DA:282,0 DA:283,0 DA:284,0 DA:285,0 DA:287,0 DA:288,0 DA:289,0 DA:290,0 DA:292,0 DA:294,0 DA:296,0 DA:297,0 DA:301,0 DA:293,0 DA:298,0 DA:300,0 DA:302,0 DA:303,0 DA:306,0 DA:308,0 DA:304,0 DA:305,0 DA:309,0 DA:310,0 DA:311,0 DA:312,0 DA:313,0 DA:314,0 DA:316,0 DA:317,0 DA:319,0 DA:320,0 DA:321,0 DA:323,0 DA:322,0 DA:324,0 DA:326,0 DA:327,0 DA:325,0 DA:328,0 DA:329,0 DA:330,0 DA:333,0 DA:331,0 DA:332,0 DA:334,0 DA:336,0 DA:335,0 DA:337,0 DA:340,0 DA:338,0 DA:341,0 DA:342,0 DA:343,0 DA:344,0 DA:345,0 DA:355,0 DA:356,0 DA:357,0 DA:358,0 DA:360,0 DA:348,0 DA:349,0 DA:350,0 DA:351,0 DA:353,0 DA:363,0 DA:364,0 DA:365,0 DA:366,0 DA:368,0 DA:369,0 DA:372,0 DA:374,0 DA:376,0 DA:377,0 DA:378,0 DA:379,0 DA:380,0 DA:382,0 DA:385,0 DA:386,0 DA:387,0 DA:388,0 DA:389,0 DA:392,0 DA:394,0 DA:390,0 DA:395,0 DA:396,0 DA:398,0 DA:400,3 DA:401,6 DA:402,6 DA:403,3 DA:397,0 DA:400,0 DA:402,0 DA:404,0 DA:406,2 DA:407,1 DA:408,0 DA:412,6 DA:413,3 DA:415,0 DA:406,0 DA:408,3 DA:409,6 DA:410,6 DA:411,3 DA:412,0 DA:414,2 DA:415,1 DA:416,0 DA:424,1 DA:425,2 DA:426,2 DA:428,0 DA:429,0 DA:432,5 DA:433,4 DA:434,8 DA:435,0 DA:437,12 DA:438,4 DA:445,1 DA:446,2 DA:447,1 DA:449,0 DA:450,0 DA:453,2 DA:454,1 DA:455,2 DA:456,0 DA:458,3 DA:459,1 DA:465,0 DA:466,0 DA:467,0 DA:469,0 DA:470,0 DA:471,0 DA:420,6 DA:421,3 DA:423,0 DA:424,0 DA:432,1 DA:433,2 DA:434,2 DA:436,0 DA:437,0 DA:440,5 DA:441,4 DA:442,8 DA:443,0 DA:445,12 DA:446,4 DA:453,1 DA:454,2 DA:455,1 DA:457,0 DA:458,0 DA:461,2 DA:462,1 DA:463,2 DA:464,0 DA:466,3 DA:467,1 DA:473,0 DA:474,0 DA:475,0 DA:477,0 DA:478,0 DA:479,0 DA:480,0 DA:481,0 DA:482,0 DA:485,0 DA:486,0 DA:487,0 DA:488,0 DA:491,0 DA:490,0 DA:493,0 DA:494,0 DA:495,0 DA:497,0 DA:498,0 DA:496,0 DA:499,0 DA:501,0 DA:502,0 DA:503,0 DA:504,0 DA:505,0 DA:507,0 DA:506,0 DA:509,0 DA:510,0 DA:511,0 DA:512,0 DA:513,0 DA:517,0 DA:515,0 DA:518,0 DA:519,0 DA:521,0 DA:522,0 DA:525,0 DA:526,0 DA:527,0 DA:528,0 DA:529,0 DA:530,0 DA:531,0 DA:533,0 DA:534,0 DA:535,0 DA:536,0 DA:537,0 DA:538,0 DA:540,0 DA:539,0 DA:541,0 DA:542,0 DA:543,0 DA:544,0 DA:545,0 DA:546,0 DA:549,0 DA:548,0 DA:551,0 DA:555,0 DA:556,0 DA:554,0 DA:557,0 DA:558,0 DA:559,0 DA:560,0 DA:563,0 DA:564,0 DA:565,0 DA:566,0 DA:567,0 DA:568,0 DA:573,0 DA:574,0 DA:575,0 DA:576,0 DA:577,0 DA:578,0 DA:579,0 DA:580,0 DA:581,0 DA:582,0 DA:583,0 DA:584,0 DA:585,0 DA:586,0 DA:587,0 DA:593,0 DA:594,0 DA:596,0 DA:597,0 DA:598,0 DA:602,3 DA:603,6 DA:604,6 DA:605,3 DA:588,0 DA:592,0 DA:595,0 DA:601,0 DA:602,0 DA:604,0 DA:605,0 DA:606,0 LF:256 DA:610,3 DA:611,6 DA:612,6 DA:613,3 DA:614,0 LF:259 LH:42 end_of_record TN: Loading pipe-lib/src/config.rs +8 −0 Original line number Diff line number Diff line Loading @@ -120,8 +120,16 @@ impl Config { let config_vars = self.variables.clone().unwrap_or_default(); let module_vars = module.unwrap().variables.clone().unwrap_or_default(); let mut envs = EnvironmentValue::get_from_serde(&config_vars); let parent = PathBuf::from(input.clone().unwrap_or_default()) .file_name() .unwrap() .to_str() .unwrap() .to_string(); envs.extend(EnvironmentValue::get_from_serde(&module_vars)); envs.insert("INPUT".to_string(), input.unwrap_or_default()); envs.insert("INPUT_PARENT".to_string(), parent); println!("Envs: {:#?}", envs); envs } /// Get inputs from input attribute for concurrent workflow execution Loading Loading
Cargo.lock +3 −3 Original line number Diff line number Diff line # This file is automatically @generated by Cargo. # It is not intended for manual editing. version = 3 version = 4 [[package]] name = "addr2line" Loading Loading @@ -2235,7 +2235,7 @@ checksum = "8b870d8c151b6f2fb93e84a13146138f05d02ed11c7e7c54f8826aaaf7c9f184" [[package]] name = "pipe-cli" version = "0.0.6" version = "0.0.7" dependencies = [ "assert_cmd", "cargo-watch", Loading @@ -2261,7 +2261,7 @@ dependencies = [ [[package]] name = "pipe-lib" version = "0.0.6" version = "0.0.7" dependencies = [ "bon", "bytes", Loading
Cargo.toml +1 −1 Original line number Diff line number Diff line Loading @@ -3,7 +3,7 @@ members = ["pipe-cli", "pipe-lib"] resolver = "2" [workspace.package] version = "0.0.6" version = "0.0.7" authors = ["Jason Wohlgemuth <wohlgemuthjh@ornl.gov>"] description = "Parallel Integration and Processing Engine" documentation = "https://pipe.ornl.gov" Loading
lcov.info +170 −167 Original line number Diff line number Diff line Loading @@ -271,18 +271,18 @@ end_of_record TN: SF:/root/dev/command/pipe-lib/src/config.rs FN:119,Config::get_environment_variables FN:131,Config::get_inputs FN:161,Config::get_module_list FN:176,Config::prepare_modules FN:400,Config::read FN:424,Config::read_json FN:445,Config::read_yaml FN:465,Config::run_workflow FN:555,Config::set_environment_variables FN:573,Config::verify_requirements FN:593,Config::verify_resources FN:596,Config::with_options FN:602,Extension::from_string FN:139,Config::get_inputs FN:169,Config::get_module_list FN:184,Config::prepare_modules FN:408,Config::read FN:432,Config::read_json FN:453,Config::read_yaml FN:473,Config::run_workflow FN:563,Config::set_environment_variables FN:581,Config::verify_requirements FN:601,Config::verify_resources FN:604,Config::with_options FN:610,Extension::from_string FNF:13 FNDA:0,Config::get_environment_variables FNDA:1,Config::get_inputs Loading @@ -302,258 +302,261 @@ DA:120,0 DA:121,0 DA:122,0 DA:123,0 DA:124,0 DA:125,0 DA:131,1 DA:132,1 DA:133,1 DA:134,1 DA:135,2 DA:136,2 DA:138,3 DA:139,2 DA:129,0 DA:130,0 DA:131,0 DA:132,0 DA:133,0 DA:139,1 DA:140,1 DA:142,0 DA:143,0 DA:147,0 DA:148,0 DA:152,1 DA:153,0 DA:158,0 DA:161,1 DA:162,2 DA:165,2 DA:167,2 DA:176,0 DA:177,0 DA:178,0 DA:180,0 DA:181,0 DA:141,1 DA:142,1 DA:143,2 DA:144,2 DA:146,3 DA:147,2 DA:148,1 DA:150,0 DA:151,0 DA:155,0 DA:156,0 DA:160,1 DA:161,0 DA:166,0 DA:169,1 DA:170,2 DA:173,2 DA:175,2 DA:184,0 DA:185,0 DA:186,0 DA:188,0 DA:189,0 DA:190,0 DA:191,0 DA:192,0 DA:193,0 DA:194,0 DA:196,0 DA:197,0 DA:198,0 DA:199,0 DA:200,0 DA:201,0 DA:202,0 DA:203,0 DA:204,0 DA:205,0 DA:206,0 DA:207,0 DA:208,0 DA:209,0 DA:210,0 DA:211,0 DA:212,0 DA:214,0 DA:213,0 DA:215,0 DA:216,0 DA:217,0 DA:218,0 DA:219,0 DA:221,0 DA:226,0 DA:232,0 DA:220,0 DA:222,0 DA:227,0 DA:229,0 DA:234,0 DA:237,0 DA:240,0 DA:242,0 DA:244,0 DA:248,0 DA:251,0 DA:254,0 DA:245,0 DA:250,0 DA:252,0 DA:256,0 DA:258,0 DA:259,0 DA:260,0 DA:261,0 DA:263,0 DA:262,0 DA:264,0 DA:266,0 DA:267,0 DA:268,0 DA:269,0 DA:270,0 DA:273,0 DA:275,0 DA:271,0 DA:272,0 DA:276,0 DA:277,0 DA:279,0 DA:280,0 DA:278,0 DA:281,0 DA:282,0 DA:283,0 DA:284,0 DA:285,0 DA:287,0 DA:288,0 DA:289,0 DA:290,0 DA:292,0 DA:294,0 DA:296,0 DA:297,0 DA:301,0 DA:293,0 DA:298,0 DA:300,0 DA:302,0 DA:303,0 DA:306,0 DA:308,0 DA:304,0 DA:305,0 DA:309,0 DA:310,0 DA:311,0 DA:312,0 DA:313,0 DA:314,0 DA:316,0 DA:317,0 DA:319,0 DA:320,0 DA:321,0 DA:323,0 DA:322,0 DA:324,0 DA:326,0 DA:327,0 DA:325,0 DA:328,0 DA:329,0 DA:330,0 DA:333,0 DA:331,0 DA:332,0 DA:334,0 DA:336,0 DA:335,0 DA:337,0 DA:340,0 DA:338,0 DA:341,0 DA:342,0 DA:343,0 DA:344,0 DA:345,0 DA:355,0 DA:356,0 DA:357,0 DA:358,0 DA:360,0 DA:348,0 DA:349,0 DA:350,0 DA:351,0 DA:353,0 DA:363,0 DA:364,0 DA:365,0 DA:366,0 DA:368,0 DA:369,0 DA:372,0 DA:374,0 DA:376,0 DA:377,0 DA:378,0 DA:379,0 DA:380,0 DA:382,0 DA:385,0 DA:386,0 DA:387,0 DA:388,0 DA:389,0 DA:392,0 DA:394,0 DA:390,0 DA:395,0 DA:396,0 DA:398,0 DA:400,3 DA:401,6 DA:402,6 DA:403,3 DA:397,0 DA:400,0 DA:402,0 DA:404,0 DA:406,2 DA:407,1 DA:408,0 DA:412,6 DA:413,3 DA:415,0 DA:406,0 DA:408,3 DA:409,6 DA:410,6 DA:411,3 DA:412,0 DA:414,2 DA:415,1 DA:416,0 DA:424,1 DA:425,2 DA:426,2 DA:428,0 DA:429,0 DA:432,5 DA:433,4 DA:434,8 DA:435,0 DA:437,12 DA:438,4 DA:445,1 DA:446,2 DA:447,1 DA:449,0 DA:450,0 DA:453,2 DA:454,1 DA:455,2 DA:456,0 DA:458,3 DA:459,1 DA:465,0 DA:466,0 DA:467,0 DA:469,0 DA:470,0 DA:471,0 DA:420,6 DA:421,3 DA:423,0 DA:424,0 DA:432,1 DA:433,2 DA:434,2 DA:436,0 DA:437,0 DA:440,5 DA:441,4 DA:442,8 DA:443,0 DA:445,12 DA:446,4 DA:453,1 DA:454,2 DA:455,1 DA:457,0 DA:458,0 DA:461,2 DA:462,1 DA:463,2 DA:464,0 DA:466,3 DA:467,1 DA:473,0 DA:474,0 DA:475,0 DA:477,0 DA:478,0 DA:479,0 DA:480,0 DA:481,0 DA:482,0 DA:485,0 DA:486,0 DA:487,0 DA:488,0 DA:491,0 DA:490,0 DA:493,0 DA:494,0 DA:495,0 DA:497,0 DA:498,0 DA:496,0 DA:499,0 DA:501,0 DA:502,0 DA:503,0 DA:504,0 DA:505,0 DA:507,0 DA:506,0 DA:509,0 DA:510,0 DA:511,0 DA:512,0 DA:513,0 DA:517,0 DA:515,0 DA:518,0 DA:519,0 DA:521,0 DA:522,0 DA:525,0 DA:526,0 DA:527,0 DA:528,0 DA:529,0 DA:530,0 DA:531,0 DA:533,0 DA:534,0 DA:535,0 DA:536,0 DA:537,0 DA:538,0 DA:540,0 DA:539,0 DA:541,0 DA:542,0 DA:543,0 DA:544,0 DA:545,0 DA:546,0 DA:549,0 DA:548,0 DA:551,0 DA:555,0 DA:556,0 DA:554,0 DA:557,0 DA:558,0 DA:559,0 DA:560,0 DA:563,0 DA:564,0 DA:565,0 DA:566,0 DA:567,0 DA:568,0 DA:573,0 DA:574,0 DA:575,0 DA:576,0 DA:577,0 DA:578,0 DA:579,0 DA:580,0 DA:581,0 DA:582,0 DA:583,0 DA:584,0 DA:585,0 DA:586,0 DA:587,0 DA:593,0 DA:594,0 DA:596,0 DA:597,0 DA:598,0 DA:602,3 DA:603,6 DA:604,6 DA:605,3 DA:588,0 DA:592,0 DA:595,0 DA:601,0 DA:602,0 DA:604,0 DA:605,0 DA:606,0 LF:256 DA:610,3 DA:611,6 DA:612,6 DA:613,3 DA:614,0 LF:259 LH:42 end_of_record TN: Loading
pipe-lib/src/config.rs +8 −0 Original line number Diff line number Diff line Loading @@ -120,8 +120,16 @@ impl Config { let config_vars = self.variables.clone().unwrap_or_default(); let module_vars = module.unwrap().variables.clone().unwrap_or_default(); let mut envs = EnvironmentValue::get_from_serde(&config_vars); let parent = PathBuf::from(input.clone().unwrap_or_default()) .file_name() .unwrap() .to_str() .unwrap() .to_string(); envs.extend(EnvironmentValue::get_from_serde(&module_vars)); envs.insert("INPUT".to_string(), input.unwrap_or_default()); envs.insert("INPUT_PARENT".to_string(), parent); println!("Envs: {:#?}", envs); envs } /// Get inputs from input attribute for concurrent workflow execution Loading