This repository has been archived by the owner on Aug 15, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 13
/
Copy pathpsom_is_files_out_ok.m
100 lines (90 loc) · 3.41 KB
/
psom_is_files_out_ok.m
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
function [flag_ok,list_files_failed,list_jobs_failed] = psom_is_files_out_ok(files_out)
%
% _________________________________________________________________________
% SUMMARY PSOM_IS_FILES_OUT_OK
%
% Check if some files are not generated twice in a pipeline
%
% SYNTAX:
% [FLAG_OK,LIST_FILES_FAILED,LIST_JOBS_FAILED] = PSOM_IS_FILES_OUT_OK(FILES_OUT)
%
% _________________________________________________________________________
% INPUTS
%
% FILES_OUT
% (structure) the field names are identical to PIPELINE
%
% <JOB_NAME>
% (cell of strings) the list of output files for the job
%
% _________________________________________________________________________
% OUTPUTS
%
% FLAG_OK
% (boolean) FLAG_OK == 1 only if every file is created only by one
% job.
%
% LIST_FILES_FAILED
% (cell of strings) a list of the files that are being generated
% twice.
%
% LIST_JOBS_FAILED
% (cell of strings) a list of job names involved in multiple
% generation of the same file name.
%
% _________________________________________________________________________
% SEE ALSO
%
% PSOM_IS_DAG
%
% _________________________________________________________________________
% COMMENTS
%
% Copyright (c) Pierre Bellec, Montreal Neurological Institute, 2008.
% Maintainer : [email protected]
% See licensing information in the code.
% Keywords : pipeline, dependencies
% Permission is hereby granted, free of charge, to any person obtaining a copy
% of this software and associated documentation files (the "Software"), to deal
% in the Software without restriction, including without limitation the rights
% to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
% copies of the Software, and to permit persons to whom the Software is
% furnished to do so, subject to the following conditions:
%
% The above copyright notice and this permission notice shall be included in
% all copies or substantial portions of the Software.
%
% THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
% IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
% FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
% AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
% LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
% OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
% THE SOFTWARE.
%% SYNTAX
if ~exist('files_out','var')
error('SYNTAX: [FLAG_OK,LIST_FILES_FAILED,LIST_JOBS_FAILED] = PSOM_IS_FILES_OUT_OK(FILES_OUT). Type ''help psom_is_files_out_ok'' for more info.')
end
list_jobs = fieldnames(files_out);
nb_jobs = length(list_jobs);
list_files_failed = {};
list_jobs_failed = {};
list_files = psom_files2cell(files_out);
nb_files = length(list_files);
[list_files2,I,J] = unique(list_files);
nb_files2 = length(list_files2);
flag_ok = length(list_files2)==length(list_files);
if ~flag_ok
mask_files_failed = false([nb_files2 1]);
for num_f = 1:nb_files2
mask_files_failed(num_f) = sum(J==num_f)>1;
end
list_files_failed = list_files2(mask_files_failed);
mask_jobs_failed = false([nb_jobs 1]);
for num_j = 1:nb_jobs
if ~isempty(files_out.(list_jobs{num_j}))
mask_jobs_failed(num_j) = max(ismember(files_out.(list_jobs{num_j}),list_files_failed));
end
end
list_jobs_failed = list_jobs(mask_jobs_failed);
end