Lines 35-41
sub process {
Link Here
|
35 |
->store; |
35 |
->store; |
36 |
|
36 |
|
37 |
my $mmtid = $args->{mmtid}; |
37 |
my $mmtid = $args->{mmtid}; |
38 |
my $record_type = $args->{record_type}; |
|
|
39 |
my @record_ids = @{ $args->{record_ids} }; |
38 |
my @record_ids = @{ $args->{record_ids} }; |
40 |
|
39 |
|
41 |
my $report = { |
40 |
my $report = { |
Lines 92-107
sub enqueue {
Link Here
|
92 |
|
91 |
|
93 |
# TODO Raise exception instead |
92 |
# TODO Raise exception instead |
94 |
return unless exists $args->{mmtid}; |
93 |
return unless exists $args->{mmtid}; |
95 |
return unless exists $args->{record_type}; #FIXME RMME |
|
|
96 |
return unless exists $args->{record_ids}; |
94 |
return unless exists $args->{record_ids}; |
97 |
|
95 |
|
98 |
my $mmtid = $args->{mmtid}; |
96 |
my $mmtid = $args->{mmtid}; |
99 |
my $record_type = $args->{record_type}; |
|
|
100 |
my @record_ids = @{ $args->{record_ids} }; |
97 |
my @record_ids = @{ $args->{record_ids} }; |
101 |
|
98 |
|
102 |
$self->SUPER::enqueue({ |
99 |
$self->SUPER::enqueue({ |
103 |
job_size => scalar @record_ids, |
100 |
job_size => scalar @record_ids, |
104 |
job_args => {mmtid => $mmtid, record_type => $record_type, record_ids => \@record_ids,} |
101 |
job_args => {mmtid => $mmtid, record_ids => \@record_ids,} |
105 |
}); |
102 |
}); |
106 |
} |
103 |
} |
107 |
|
104 |
|