|
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 |
|