Changeset 26867
- Timestamp:
- Feb 10, 2010, 4:07:44 PM (16 years ago)
- Location:
- branches/eam_branches/20091201/ippTasks
- Files:
-
- 8 edited
-
Makefile.am (modified) (1 diff)
-
chip.pro (modified) (1 diff)
-
destreak.pro (modified) (1 diff)
-
diff.pro (modified) (2 diffs)
-
dist.cleanup.pro (modified) (2 diffs)
-
magic.pro (modified) (5 diffs)
-
summit.copy.pro (modified) (8 diffs)
-
warp.pro (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
-
branches/eam_branches/20091201/ippTasks/Makefile.am
r26087 r26867 29 29 receive.pro \ 30 30 publish.pro \ 31 science.cleanup.pro 31 dqstats.pro \ 32 science.cleanup.pro \ 33 nightly_stacks.pro 32 34 33 35 other_files = \ -
branches/eam_branches/20091201/ippTasks/chip.pro
r25693 r26867 138 138 book getword chipPendingImfile $pageName state -var RUN_STATE 139 139 140 if ( "$RAW_MAGICKED" == "T")141 $MAGICKED_ARG = "--magicked "140 if ($RAW_MAGICKED > 0) 141 $MAGICKED_ARG = "--magicked $RAW_MAGICKED" 142 142 else 143 143 $MAGICKED_ARG = "" -
branches/eam_branches/20091201/ippTasks/destreak.pro
r26075 r26867 226 226 # TODO: do not add recoveryroot or replace if they are null or zero 227 227 228 $run = magic_destreak.pl --magic_ds_id $MAGIC_DS_ID --camera $CAMERA -- streaks $STREAKS --inv_streaks $INV_STREAKS --stage $STAGE --stage_id $STAGE_ID --component $COMPONENT --uri $URI --path_base $PATH_BASE --cam_path_base $CAM_PATH_BASE --outroot $OUTROOT --logfile $logfile --recoveryroot $RECROOT --replace $REPLACE228 $run = magic_destreak.pl --magic_ds_id $MAGIC_DS_ID --camera $CAMERA --exp_id $EXP_ID --streaks $STREAKS --inv_streaks $INV_STREAKS --stage $STAGE --stage_id $STAGE_ID --component $COMPONENT --uri $URI --path_base $PATH_BASE --cam_path_base $CAM_PATH_BASE --outroot $OUTROOT --logfile $logfile --recoveryroot $RECROOT --replace $REPLACE 229 229 230 230 add_standard_args run -
branches/eam_branches/20091201/ippTasks/diff.pro
r26752 r26867 155 155 book getword diffSkyfile $pageName bothways -var BOTHWAYS 156 156 book getword diffSkyfile $pageName workdir -var WORKDIR_TEMPLATE 157 book getword diffSkyfile $pageName state -var RUN_STATE 157 158 book getword diffSkyfile $pageName dbname -var DBNAME 158 159 book getword diffSkyfile $pageName reduction -var REDUCTION … … 172 173 stderr $LOGDIR/diff.skycell.log 173 174 174 $run = diff_skycell.pl --threads @MAX_THREADS@ --diff_id $DIFF_ID --skycell_id $SKYCELL_ID --diff_skyfile_id $DIFF_SKYFILE_ID --outroot $outroot --redirect-output 175 $run = diff_skycell.pl --threads @MAX_THREADS@ --diff_id $DIFF_ID --skycell_id $SKYCELL_ID --diff_skyfile_id $DIFF_SKYFILE_ID --outroot $outroot --redirect-output --run-state $RUN_STATE 175 176 if ("$BOTHWAYS" == "T") 176 177 $run = $run --inverse -
branches/eam_branches/20091201/ippTasks/dist.cleanup.pro
r26087 r26867 48 48 49 49 stdout NULL 50 stderr $LOGDIR/dist.cleanup.lo g50 stderr $LOGDIR/dist.cleanup.load.log 51 51 52 52 task.exec 53 53 if ($LABEL:n == 0) break 54 $run = disttool -pendingcleanup 54 $run = disttool -pendingcleanup -all 55 55 if ($DB:n == 0) 56 56 option DEFAULT … … 98 98 periods -poll $RUNPOLL 99 99 periods -exec $RUNEXEC 100 periods -timeout 60 100 periods -timeout 600 101 101 active false 102 102 -
branches/eam_branches/20091201/ippTasks/magic.pro
r26812 r26867 14 14 $magicToTree_DB = 0 15 15 $magicToProcess_DB = 0 16 $magicRevertTree_DB = 0 17 $magicRevertNode_DB = 0 16 18 17 19 ### Check status of tasks … … 28 30 29 31 ### Turn tasks on 32 macro magic.revert.on 33 task magic.revert.node 34 active true 35 end 36 task magic.revert.tree 37 active true 38 end 39 end 40 30 41 macro magic.on 31 42 task magic.tree.load … … 40 51 task magic.process.run 41 52 active true 53 end 54 magic.revert.on 55 end 56 57 macro magic.revert.off 58 task magic.revert.node 59 active false 60 end 61 task magic.revert.tree 62 active false 42 63 end 43 64 end … … 57 78 active false 58 79 end 80 magic.revert.off 59 81 end 60 82 … … 325 347 end 326 348 end 349 350 task magic.revert.node 351 host local 352 353 periods -poll 5.0 354 periods -exec 60.0 355 periods -timeout 120.0 356 npending 1 357 358 stdout NULL 359 stderr $LOGSUBDIR/revertnode.log 360 361 task.exec 362 if ($LABEL:n == 0) break 363 $run = magictool -revertnode 364 if ($DB:n == 0) 365 option DEFAULT 366 else 367 # save the DB name for the exit tasks 368 option $DB:$magicRevertNode_DB 369 $run = $run -dbname $DB:$magicRevertNode_DB 370 $magicRevertNode_DB ++ 371 if ($magicRevertNode_DB >= $DB:n) set magicRevertNode_DB = 0 372 end 373 add_poll_labels run 374 command $run 375 end 376 377 # success 378 task.exit 0 379 end 380 381 # locked list 382 task.exit default 383 showcommand failure 384 end 385 386 task.exit crash 387 showcommand crash 388 end 389 390 # operation times out? 391 task.exit timeout 392 showcommand timeout 393 end 394 end 395 task magic.revert.tree 396 host local 397 398 periods -poll 5.0 399 periods -exec 60.0 400 periods -timeout 120.0 401 npending 1 402 403 stdout NULL 404 stderr $LOGSUBDIR/reverttree.log 405 406 task.exec 407 if ($LABEL:n == 0) break 408 $run = magictool -reverttree 409 if ($DB:n == 0) 410 option DEFAULT 411 else 412 # save the DB name for the exit tasks 413 option $DB:$magicRevertTree_DB 414 $run = $run -dbname $DB:$magicRevertTree_DB 415 $magicRevertTree_DB ++ 416 if ($magicRevertTree_DB >= $DB:n) set magicRevertTree_DB = 0 417 end 418 add_poll_labels run 419 command $run 420 end 421 422 # success 423 task.exit 0 424 end 425 426 # locked list 427 task.exit default 428 showcommand failure 429 end 430 431 task.exit crash 432 showcommand crash 433 end 434 435 # operation times out? 436 task.exit timeout 437 showcommand timeout 438 end 439 end -
branches/eam_branches/20091201/ippTasks/summit.copy.pro
r25340 r26867 111 111 112 112 task.exec 113 # echo "DB_DEBUG: PRE" $pztoolDatastore_DB $DB:$pztoolDatastore_DB 113 114 if ($DB:n == 0) 114 115 option DEFAULT … … 121 122 if ($pztoolDatastore_DB >= $DB:n) set pztoolDatastore_DB = 0 122 123 end 124 125 # More debug 126 # echo "DB_DEBUG: POST" $pztoolDatastore_DB $DB:$pztoolDatastore_DB 123 127 periods -exec 120 124 128 end … … 127 131 task.exit 0 128 132 # flush pzDataStore book 129 book init pzDataStore133 # book init pzDataStore 130 134 # convert 'stdout' to book format 131 135 ipptool2book stdout pzDataStore -key camera:telescope -uniq -setword dbname $options:0 … … 147 151 # run pzgetexp periodically to populate pzPendingExp in the database (no I/O) 148 152 # this task is querying the data store for a list of exposures ("filesets") 149 # and inserting these into a db table on the local cluster (pz PendingExp)153 # and inserting these into a db table on the local cluster (pzDownloadExp) 150 154 task pzgetexp 151 155 periods -exec 30 … … 379 383 periods -exec 5 380 384 periods -poll 0.05 381 periods -timeout 650385 periods -timeout 1150 382 386 trange -reset 383 387 # only active in the night (18:00 to 06:00 HST, times are UT): … … 446 450 stderr $LOGDIR/summit.copy.log 447 451 448 $run = summit_copy.pl --uri $URI --filename $FILENAME --exp_name $EXP_NAME --inst $CAMERA --telescope $TELESCOPE --class $CLASS --class_id $CLASS_ID --bytes $BYTES --md5 $MD5SUM --dbname $DBNAME --timeout 120 --verbose --copies 2 449 if ($COMPRESS) 452 book getpage pzDataStore 0 -var PZDSPAGE -key dbname $DBNAME 453 book getword pzDataStore $PZDSPAGE use_compress -var USECOMPRESS 454 455 # Debug line 456 # echo "DEBUG: " $DBNAME $EXP_NAME $CAMERA $PZDSPAGE $USECOMPRESS 457 458 # unconditionally turn on requesting compression until we figuure 459 # out why the above doesn't work 460 if ($USECOMPRESS == "NULL") 461 # if ("$CAMERA" == "gpc1") 462 $USECOMPRESS = 1 463 end 464 465 $run = summit_copy.pl --uri $URI --filename $FILENAME --exp_name $EXP_NAME --inst $CAMERA --telescope $TELESCOPE --class $CLASS --class_id $CLASS_ID --bytes $BYTES --md5 $MD5SUM --dbname $DBNAME --timeout 600 --verbose --copies 2 466 if ($USECOMPRESS == 1) 450 467 $run = $run --compress 451 else 452 $run = $run --bytes $BYTES 453 end 454 if (("$MD5SUM" != "NULL") && ("$MD5SUM" != "0") && (not($COMPRESS))) 468 end 469 # if (("$MD5SUM" != "NULL") && ("$MD5SUM" != "0") && (not($COMPRESS))) 455 470 # && (($YEAR > 2008) || (("$YEAR" = "2007") && ($MONTH > 8)))) 456 $run = $run --md5 $MD5SUM457 end471 # $run = $run --md5 $MD5SUM 472 # end 458 473 if ($NEBULOUS) 459 474 $run = $run --nebulous … … 463 478 # store the pageName for future reference below 464 479 options $pageName 465 480 466 481 # create the command line 467 482 if ($VERBOSE > 1) 468 483 echo command $run 469 484 end 485 # More debug: 486 # echo "DEBUG2: " $run 470 487 command $run 471 488 end … … 506 523 if ($pztoolClearFault_DB >= $DB:n) set pztoolClearFault_DB = 0 507 524 end 508 periods -exec 600525 periods -exec 1800 509 526 end 510 527 -
branches/eam_branches/20091201/ippTasks/warp.pro
r25693 r26867 295 295 book getword warpPendingSkyCell $pageName state -var RUN_STATE 296 296 book getword warpPendingSkyCell $pageName magicked -var CHIP_MAGICKED 297 if ( "$CHIP_MAGICKED" == "T")298 $MAGICKED_ARG = "--magicked "297 if ($CHIP_MAGICKED > 0) 298 $MAGICKED_ARG = "--magicked $CHIP_MAGICKED" 299 299 else 300 300 $MAGICKED_ARG = ""
Note:
See TracChangeset
for help on using the changeset viewer.
