Index: trunk/pstamp/scripts/pstamp_finish.pl =================================================================== --- trunk/pstamp/scripts/pstamp_finish.pl (revision 25540) +++ trunk/pstamp/scripts/pstamp_finish.pl (revision 25712) @@ -81,12 +81,4 @@ my $fileset = $req_name; - - # Here we invoke the assumption that the output for the request is placed in the - # fileset directory directly -# my $out_dir = "$outputDataStoreRoot/$product/$fileset"; - - # now we are assuming that the output directory is the dirname of the request file - # XXX: put this in the database - print STDERR "product: $product REQ_NAME: $req_name $out_dir\n" if $verbose; @@ -216,6 +208,9 @@ # ra_deg and dec_deg are the coordinates of center of the stamp - # XXX: parse the stamp header to find it - print $tdf "0.0|0.0|"; + # XXX do this more cleanly + my (undef, $ra_deg, $dec_deg) = split " ", `echo $out_dir/$img_name | fields RA_DEG DEC_DEG`; + $ra_deg = 0.0 if (!$ra_deg); + $dec_deg = 0.0 if (!$dec_deg); + print $tdf "$ra_deg|$dec_deg|"; print $tdf "$exp_info|"; Index: trunk/pstamp/scripts/pstamp_job_run.pl =================================================================== --- trunk/pstamp/scripts/pstamp_job_run.pl (revision 25540) +++ trunk/pstamp/scripts/pstamp_job_run.pl (revision 25712) @@ -16,4 +16,5 @@ use PS::IPP::PStamp::RequestFile qw( :standard ); use IPC::Cmd 0.36 qw( can_run run ); +use POSIX; use PS::IPP::Metadata::Config; @@ -93,5 +94,13 @@ run(command => $command, verbose => $verbose); - if ($success) { + my $exitStatus; + if (WIFEXITED($error_code)) { + $exitStatus = WEXITSTATUS($error_code); + } else { + print STDERR "ppstamp failed error_code: $error_code\n"; + $exitStatus = $PS_EXIT_SYS_ERROR; + } + + if ($exitStatus == 0) { my $dir = dirname($outputBase); @@ -133,7 +142,8 @@ close F; $jobStatus = $PS_EXIT_SUCCESS; - } else { - $jobStatus = $error_code >> 8; - my_die( "ppstamp failed with error code: $jobStatus", $job_id, $jobStatus); + } elsif ($exitStatus == $PSTAMP_NO_OVERLAP) { + $jobStatus = $PSTAMP_NO_OVERLAP + } else { + my_die( "ppstamp failed with error code: $exitStatus", $job_id, $exitStatus); } } elsif ($jobType eq "get_image") { @@ -162,4 +172,5 @@ { my $command = "$pstamptool -updatejob -job_id $job_id -state stop"; + $command .= " -fault $jobStatus" if $jobStatus; $command .= " -dbname $dbname" if $dbname; $command .= " -dbserver $dbserver" if $dbserver; Index: trunk/pstamp/scripts/pstampparse.pl =================================================================== --- trunk/pstamp/scripts/pstampparse.pl (revision 25540) +++ trunk/pstamp/scripts/pstampparse.pl (revision 25712) @@ -16,5 +16,5 @@ use File::Basename qw(basename); use Carp; -use POSIX qw( strftime ); +use POSIX; my $verbose; @@ -72,4 +72,5 @@ } +# list_job is a deugging mode $no_update = 1 if $mode eq "list_job"; @@ -185,11 +186,13 @@ } my $req_type = $row->{REQ_TYPE}; - $stage = $row->{IMG_TYPE}; - my $id = $row->{ID}; + $stage = $row->{IMG_TYPE}; + my $id = $row->{ID}; my $component = $row->{COMPONENT}; - - my $filter = $row->{REQFILT}; + my $tess_id = $row->{TESS_ID}; + + my $filter = $row->{REQFILT}; my $mjd_min = $row->{MJD_MIN}; my $mjd_max = $row->{MJD_MAX}; + my $label = $row->{LABEL}; my $option_mask= $row->{OPTION_MASK}; @@ -222,5 +225,4 @@ my_die("job_type is list_uri but mode is $mode", $PS_EXIT_PROG_ERROR) if ($job_type eq "list_uri") and ($mode ne "list_uri"); - my $image_db = $proj_hash->{dbname}; my $camera = $proj_hash->{camera}; @@ -228,5 +230,5 @@ # Temporary hack so that MOPS can get at non-magicked data - if ($product eq "mops-pstamp-results") { + if ($product and ($product eq "mops-pstamp-results")) { $need_magic = 0; } @@ -269,6 +271,6 @@ my ($x, $y); - $imageList = locate_images($ipprc, $image_db, $req_type, $stage, $id, $search_component, - $inverse, $skycenter, $x, $y, $mjd_min, $mjd_max, $filter, $verbose); + $imageList = locate_images($ipprc, $image_db, $req_type, $stage, $id, $tess_id, $search_component, + $inverse, $need_magic, $x, $y, $mjd_min, $mjd_max, $filter, $label, $verbose); if (!$imageList or !@$imageList) { @@ -305,4 +307,5 @@ my $num_jobs = 0; my $rownum = $row->{ROWNUM}; + my $option_mask = $row->{OPTION_MASK}; my $components = $row->{components}; @@ -346,4 +349,6 @@ if (($stage ne "stack") and ($need_magic and !$image->{magicked})) { # XXX: should we add a faulted job so the client can know what happened if no images come back? + # This test is made in locate_images now so this code never runs. This leads to no feedback + # to users, but speeds up processing significatnly print STDERR "skipping non-magicked image $imagefile\n" if $verbose; @@ -369,8 +374,8 @@ $args .= " -file $imagefile"; - if (($row->{OPTION_MASK} & $PSTAMP_SELECT_MASK) && $image->{mask} ) { + if (($option_mask & $PSTAMP_SELECT_MASK) && $image->{mask} ) { $args .= " -mask $image->{mask}"; } - if (($row->{OPTION_MASK} & $PSTAMP_SELECT_WEIGHT) and $image->{weight} ) { + if (($option_mask & $PSTAMP_SELECT_WEIGHT) and $image->{weight} ) { $args .= " -variance $image->{weight}"; } @@ -407,5 +412,5 @@ $num_jobs++; my $command = "$pstamptool -addjob -req_id $req_id -job_type $row->{JOB_TYPE}" - . " -outputBase $output_base -rownum $rownum -state $newState"; + . " -outputBase $output_base -rownum $rownum -state $newState -options $option_mask"; $command .= " -fault $fault" if $fault; $command .= " -exp_id $exp_id" if $exp_id; @@ -542,7 +547,11 @@ run(command => $command, verbose => $verbose); unless ($success) { - print STDERR @$stderr_buf; - my $rc = $error_code >> 8; - my_die( "dvoImagesAtCoords failed: $rc", $PS_EXIT_UNKNOWN_ERROR); + # don't fail if the program exited normally and exit status was PSTAMP_NO_OVERLAP + # That just means that the coordinate didn't match any image/skycell + if (!WIFEXITED($error_code) || (WEXITSTATUS($error_code) ne $PSTAMP_NO_OVERLAP)) { + print STDERR @$stderr_buf; + my $rc = WIFEXITED($error_code) ? WEXITSTATUS($error_code) : $PS_EXIT_SYS_ERROR; + my_die( "dvoImagesAtCoords failed: $rc", $rc); + } } # now we have a list of row numbers and components