Rebuild jobs by uuid as needed

bobtfish · Feb 2, 2011 · 09b8dec · 09b8dec
1 parent 359f51a
commit 09b8dec
Showing 1 changed file with 15 additions and 1 deletion.
diff --git a/lib/CatalystX/JobServer/TraitFor/JobRunner/JobsByUUID.pm b/lib/CatalystX/JobServer/TraitFor/JobRunner/JobsByUUID.pm
@@ -9,13 +9,27 @@ has jobs_by_uuid => (
     is => 'ro',
     traits    => ['Hash', 'Serialize'],
     isa => HashRef[Running],
-    default => sub { {} },
+    lazy => 1,
+    builder => '_build_jobs_by_uuid',
     handles   => {
         _add_job_by_uuid => 'set',
         _remove_job_by_uuid => 'delete',
     },
+    clearer => '_clear_jobs_by_uuid',
 );
 
+before pack => sub {
+    shift->_clear_jobs_by_uuid;
+};
+method _build_jobs_by_uuid {
+    return {
+        map { $_->working_on->job->{uuid}, $_->working_on }
+        grep { $_->working_on->job->{uuid} }
+        grep { $_->working_on }
+        $self->workers->flatten
+    };
+}
+
 has _jobs_by_uuid_handles => (
     is => 'ro',
     isa => HashRef,