IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Changeset 41213 for trunk/ippTools


Ignore:
Timestamp:
Dec 24, 2019, 2:57:20 AM (7 years ago)
Author:
cclin33
Message:

update for addstar tasks

Location:
trunk/ippTools
Files:
13 edited

Legend:

Unmodified
Added
Removed
  • trunk/ippTools/share/addtool_find_pendingexp_cam.sql

    r31375 r41213  
    77    rawExp.camera,
    88    rawExp.telescope,
    9     rawExp.filelevel
     9    rawExp.filelevel,
     10    minidvodbRun.minidvodb_host as dvodbhost
    1011FROM addRun
     12JOIN minidvodbRun
     13    on addRun.minidvodb_group = minidvodbRun.minidvodb_group
    1114JOIN camRun
    1215    on cam_id = stage_id
     
    2831    AND addRun.workdir IS NOT NULL
    2932    AND addMask.label IS NULL
     33    AND minidvodbRun.state = 'active'
    3034
  • trunk/ippTools/share/addtool_queue_cam_id.sql

    r32832 r41213  
    1616        %d,             -- minidvodb
    1717        '%s',           -- minidvodb_group
    18         '%s'            -- minidvodb_name
     18        '%s',           -- minidvodb_name
     19        '%s'            -- minidvodb_host
    1920    FROM camRun
    2021    WHERE
  • trunk/ippTools/share/addtool_queue_ff_id.sql

    r37709 r41213  
    1616        %d,             -- minidvodb
    1717        '%s',           -- minidvodb_group
    18         '%s'            -- minidvodb_name
     18        '%s',           -- minidvodb_name
     19        '%s'            -- minidvodb_host
    1920    FROM fullForceRun
    2021    WHERE
  • trunk/ippTools/share/addtool_queue_ffsummary.sql

    r38943 r41213  
    1616        %d,             -- minidvodb
    1717        '%s',           -- minidvodb_group
    18         '%s'            -- minidvodb_name
     18        '%s',           -- minidvodb_name
     19        '%s'            -- minidvodb_host
    1920    FROM fullForceRun
    2021    WHERE
  • trunk/ippTools/share/addtool_queue_sky_id.sql

    r32832 r41213  
    1616        %d,             -- minidvodb
    1717        '%s',           -- minidvodb_group
    18         '%s'            -- minidvodb_name
     18        '%s',           -- minidvodb_name
     19        '%s'            -- minidvodb_host
    1920    FROM staticskyRun
    2021    WHERE
  • trunk/ippTools/share/addtool_queue_skycal_id.sql

    r34265 r41213  
    1616        %d,             -- minidvodb
    1717        '%s',           -- minidvodb_group
    18         '%s'            -- minidvodb_name
     18        '%s',           -- minidvodb_name
     19        '%s'            -- minidvodb_host
    1920    FROM skycalRun
    2021    WHERE
  • trunk/ippTools/share/addtool_queue_stack_id.sql

    r32832 r41213  
    1616        %d,             -- minidvodb
    1717        '%s',           -- minidvodb_group
    18         '%s'            -- minidvodb_name
     18        '%s',           -- minidvodb_name
     19        '%s'            -- minidvodb_host
    1920    FROM stackRun
    2021    WHERE
  • trunk/ippTools/src/addtool.c

    r41072 r41213  
    134134    PXOPT_LOOKUP_STR(minidvodb_name,  config->args, "-set_minidvodb_name", false, false);
    135135    PXOPT_LOOKUP_STR(minidvodb_group, config->args, "-set_minidvodb_group", false, false);
     136    PXOPT_LOOKUP_STR(minidvodb_host,  config->args, "-set_minidvodb_host",  false, false);
    136137    PXOPT_LOOKUP_BOOL(image_only, config->args, "-image_only", false);
    137138    PXOPT_LOOKUP_BOOL(minidvodb,  config->args, "-set_minidvodb", false);
    138139    PXOPT_LOOKUP_BOOL(destreaked, config->args, "-destreaked", false);
    139140    PXOPT_LOOKUP_BOOL(uncensored, config->args, "-uncensored", false);
    140 
    141141    PXOPT_LOOKUP_U64(limit, config->args, "-limit", false, false);
    142142
     
    155155      pxAddLabelSearchArgs (config, where, "-label",     "camRun.label", "=="); // define using camRun label
    156156      pxAddLabelSearchArgs (config, where, "-data_group","camRun.data_group", "=="); // define using camRun label
     157      pxAddLabelSearchArgs (config, where,     "-filter",   "rawExp.filter", "LIKE"); // define using camRun label
    157158      PXOPT_COPY_STR(config->args, where,  "-reduction", "camRun.reduction", "==");
    158159    }
     
    703704                               minidvodb,
    704705                               minidvodb_group,
    705                                minidvodb_name
     706                               minidvodb_name,
     707                               minidvodb_host
    706708                               )) {
    707709          if (!psDBRollback(config->dbh)) {
     
    745747                               minidvodb,
    746748                               minidvodb_group,
    747                                minidvodb_name
     749                               minidvodb_name,
     750                               minidvodb_host
    748751                               )) {
    749752          if (!psDBRollback(config->dbh)) {
     
    779782          return false;
    780783        }
    781        
    782784        // queue the exp
    783785        //for (int filter_id = 0; filter_id < num_inputs; filter_id++) { 
     
    795797                               minidvodb,
    796798                               minidvodb_group,
    797                                minidvodb_name
     799                               minidvodb_name,
     800                               minidvodb_host
    798801                               )) {
    799802          if (!psDBRollback(config->dbh)) {
     
    838841                               minidvodb,
    839842                               minidvodb_group,
    840                                minidvodb_name
     843                               minidvodb_name,
     844                               minidvodb_host
    841845                               )) {
    842846          if (!psDBRollback(config->dbh)) {
     
    886890                               minidvodb,
    887891                               minidvodb_group,
    888                                minidvodb_name
     892                               minidvodb_name,
     893                               minidvodb_host
    889894                               )) {
    890895          if (!psDBRollback(config->dbh)) {
     
    934939                               minidvodb,
    935940                               minidvodb_group,
    936                                minidvodb_name
     941                               minidvodb_name,
     942                               minidvodb_host
    937943                               )) {
    938944          if (!psDBRollback(config->dbh)) {
     
    976982                               minidvodb,
    977983                               minidvodb_group,
    978                                minidvodb_name
     984                               minidvodb_name,
     985                               minidvodb_host
    979986                               )) {
    980987          if (!psDBRollback(config->dbh)) {
     
    12031210    PXOPT_LOOKUP_STR(dvodb_path, config->args, "-dvodb_path", false, false);
    12041211    PXOPT_LOOKUP_STR(minidvodb_name, config->args, "-minidvodb_name", false, false);
     1212    PXOPT_LOOKUP_STR(minidvodb_host, config->args, "-minidvodb_host", false, false);
    12051213    PXOPT_LOOKUP_S16(fault,         config->args, "-fault", false, false);
    12061214    PXOPT_LOOKUP_S64(stage_extra1, config->args, "-stage_extra1", false, false);
     
    13171325        }
    13181326      }
     1327
     1328      //if there is a minidvodb_host, set it in addRun (it's not known until it is processed)
     1329      if (minidvodb_host) {
     1330        psString setName = NULL;
     1331        psStringAppend (&setName, "UPDATE addRun set minidvodb_host = '%s' where add_id = %" PRId64, minidvodb_host, row->add_id);
     1332        if (!p_psDBRunQuery(config->dbh, setName)) {
     1333          if (!psDBRollback(config->dbh)) {
     1334            psError(PS_ERR_UNKNOWN, false, "database error");
     1335          }
     1336          psError(PS_ERR_UNKNOWN, false, "database error");
     1337         
     1338          return false;
     1339        }
     1340      }
     1341
    13191342      //if there is a stage_extra1, set it in addRun (it's not known until it is processed)
    13201343      if (stage_extra1) {
     
    13321355        }
    13331356      }
    1334      
    1335      
    1336      
    13371357     
    13381358      // since there is only one exp per 'new' set addRun.state = 'full'
     
    16631683  // required
    16641684  PXOPT_LOOKUP_STR(minidvodb_group, config->args, "-set_minidvodb_group", true, false);
    1665 
     1685  PXOPT_LOOKUP_STR(minidvodb_path, config->args, "-set_minidvodb_path", false, false);
     1686  PXOPT_LOOKUP_STR(minidvodb_host, config->args, "-set_minidvodb_host", false, false);
    16661687  //optional
    16671688  PXOPT_LOOKUP_STR(minidvodb_name, config->args, "-set_minidvodb_name", false, false);
    1668   PXOPT_LOOKUP_STR(minidvodb_path, config->args, "-set_minidvodb_path", false, false);
    16691689  PXOPT_LOOKUP_STR(state, config->args, "-set_state", false, false);
    1670  
     1690  PXOPT_LOOKUP_STR(note,            config->args, "-set_note",            false, false);
    16711691
    16721692  if (!psDBTransaction(config->dbh)) {
     
    16751695  }
    16761696
    1677   psString minidvodbpath = "NULL";
     1697//  psString minidvodbpath = "NULL";
    16781698
    16791699  // I don't know how to get around the complaints of minidvodb_path can't be null. this 'fixes' it, but someone smarter can fix it properly.
    1680   if (minidvodb_path) {
    1681     minidvodbpath = minidvodb_path;
    1682   } else {
    1683     psError(PS_ERR_UNKNOWN, false, "require minidvodb_path");
    1684     return false;
    1685   }
     1700//  if (minidvodb_path) {
     1701//    minidvodbpath = minidvodb_path;
     1702//  } else {
     1703//    psError(PS_ERR_UNKNOWN, false, "require minidvodb_path");
     1704//    return false;
     1705//  }
    16861706 
    16871707  if (!minidvodbRunInsert(config->dbh,
     
    16891709                          minidvodb_name,
    16901710                          minidvodb_group,
    1691                           minidvodbpath,
     1711                          minidvodb_path,
     1712                          minidvodb_host,
    16921713                          "new",
     1714                          note,
    16931715                          0
    16941716                          )) {
     
    17461768    PXOPT_LOOKUP_STR(minidvodb_name,  config->args, "-set_minidvodb_name", false, false);
    17471769    PXOPT_LOOKUP_STR(minidvodb_path,  config->args, "-set_minidvodb_path", false, false);
     1770    PXOPT_LOOKUP_STR(minidvodb_host,  config->args, "-set_minidvodb_host", false, false);
    17481771    PXOPT_LOOKUP_STR(state,  config->args, "-set_state", false, false);
    17491772    PXOPT_LOOKUP_STR(minidvodb_group,  config->args, "-set_minidvodb_group", false, false);
     
    17701793     
    17711794      psStringAppend(&query, " minidvodb_path = '%s'", minidvodb_path);
     1795      cnt++;
     1796    }
     1797
     1798    if (minidvodb_host) {
     1799      if (cnt) {
     1800        psStringAppend(&query, "%s", comma);
     1801      }
     1802     
     1803      psStringAppend(&query, " minidvodb_host = '%s'", minidvodb_host);
    17721804      cnt++;
    17731805    }
  • trunk/ippTools/src/addtoolConfig.c

    r40803 r41213  
    5959    psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-label", PS_META_DUPLICATE_OK, "search by camRun label", NULL);
    6060    psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-data_group", PS_META_DUPLICATE_OK, "search by camRun data_group", NULL);
    61     psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-filter", PS_META_DUPLICATE_OK, "search by filter", NULL);
     61    psMetadataAddStr(definebyqueryArgs,  PS_LIST_TAIL,  "-filter",        PS_META_DUPLICATE_OK, "search by rawExp filter",    NULL);
    6262    psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-reduction",          0, "search by camRun reduction class", NULL);
    6363    psMetadataAddBool(definebyqueryArgs, PS_LIST_TAIL, "-destreaked",           0, "queue destreaked runs", false);
     
    7575    psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-set_minidvodb_group", 0,   "define minidvodb_group", NULL);
    7676    psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-set_minidvodb_name", 0,   "define minidvodb_bname", NULL);
     77    psMetadataAddStr(definebyqueryArgs,  PS_LIST_TAIL, "-set_minidvodb_host",  0, "define minidvodb_host",   NULL);
    7778    psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-set_data_group", 0,   "define new data_group", NULL);
    7879    psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-set_dist_group", 0,   "define new dist_group", NULL);
     
    103104    psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_state",              0, "set state", NULL);
    104105    psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_label",              0, "set label", NULL);
    105     psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_dvodb",              0, "set dvodb", NULL);
     106//    psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_dvodb",              0, "set dvodb", NULL);
    106107    psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_data_group", 0,   "define new data_group", NULL);
    107108    psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_dist_group", 0,   "define new dist_group", NULL);
     
    133134     psMetadataAddStr(addprocessedexpArgs, PS_LIST_TAIL, "-dvodb_path", 0,            "define base output location", NULL);
    134135      psMetadataAddStr(addprocessedexpArgs, PS_LIST_TAIL, "-minidvodb_name", 0,            "define minidvodb_name", NULL);
     136    psMetadataAddStr(addprocessedexpArgs, PS_LIST_TAIL, "-minidvodb_host",    0, "define minidvodb_name", NULL);
    135137    psMetadataAddF32(addprocessedexpArgs, PS_LIST_TAIL, "-dtime_addstar", 0, "define elapsed time for DVO insertion (seconds)", NAN);
    136138    psMetadataAddS16(addprocessedexpArgs, PS_LIST_TAIL, "-fault",  0,            "set fault code", 0);
     
    190192    psMetadataAddStr(addminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_group",        0, "define minidvodb_group (required)", NULL);
    191193    psMetadataAddStr(addminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_path",        0, "define path for minidvodb", NULL);
     194    psMetadataAddStr(addminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_host",  0, "define host for minidvodb (required)", NULL);
    192195    psMetadataAddStr(addminidvodbrunArgs, PS_LIST_TAIL, "-set_state",        0, "define state", NULL);
     196    psMetadataAddStr(addminidvodbrunArgs, PS_LIST_TAIL, "-set_note",         0, "define note", NULL);
    193197
    194198    // -updateminidvodbruns
     
    202206    psMetadataAddStr(updateminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_path",        0, "define path for minidvodb", NULL);
    203207    psMetadataAddStr(updateminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_group",        0, "define path for the merged dvodb", NULL);
     208    psMetadataAddStr(updateminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_host",  0, "define host for the merged dvodb", NULL);
    204209    psMetadataAddStr(updateminidvodbrunArgs, PS_LIST_TAIL, "-set_state",        0, "define state", NULL);
    205210   
  • trunk/ippTools/src/flatcorr.c

    r32832 r41213  
    676676                0,  //The minidvodb stuff is off
    677677                NULL,
     678                NULL,
    678679                NULL)) {
    679680            if (!psDBRollback(config->dbh)) {
  • trunk/ippTools/src/pxadd.c

    r38943 r41213  
    141141                       bool minidvodb,
    142142                       char *minidvodb_group,
    143                        char *minidvodb_name)
     143                       char *minidvodb_name,
     144                       char *minidvodb_host)
    144145{
    145146    PS_ASSERT_PTR_NON_NULL(config, false);
     
    208209                         minidvodb_group,
    209210                         minidvodb_name,
     211                         minidvodb_host,
    210212                         (long long) stage_id
    211213    )) {
  • trunk/ippTools/src/pxadd.h

    r32832 r41213  
    4343                       bool minidvodb,
    4444                       char *minidvodb_group,
    45                        char *minidvodb_name);
     45                       char *minidvodb_name,
     46                       char *minidvodb_host);
    4647
    4748#endif // PXADD_H
  • trunk/ippTools/src/pxcam.c

    r41072 r41213  
    4242    psMetadataAddStr(md,  PS_LIST_TAIL, "-comment",            0, "search by comment", NULL);
    4343    psMetadataAddStr(md,  PS_LIST_TAIL, "-filelevel",          0, "search by filelevel", NULL);
    44     psMetadataAddStr(md,  PS_LIST_TAIL, "-filter",             0, "search for filter", NULL);
     44//    psMetadataAddStr(md,  PS_LIST_TAIL, "-filter",             0, "search for filter", NULL);
    4545    psMetadataAddF64(md,  PS_LIST_TAIL, "-airmass_min",        0, "define min airmass", NAN);
    4646    psMetadataAddF64(md,  PS_LIST_TAIL, "-airmass_max",        0, "define max airmass", NAN);
     
    8787    PXOPT_COPY_STR(config->args,   where, "-comment",            "rawExp.comment",       "LIKE");
    8888    PXOPT_COPY_STR(config->args,   where, "-filelevel",          "rawExp.filelevel",     "==");
    89     PXOPT_COPY_STR(config->args,   where, "-filter",             "rawExp.filter",         "LIKE");
     89//    PXOPT_COPY_STR(config->args,   where, "-filter",             "rawExp.filter",         "LIKE");
    9090    PXOPT_COPY_F64(config->args,   where, "-airmass_min",        "rawExp.airmass",        ">=");
    9191    PXOPT_COPY_F64(config->args,   where, "-airmass_max",        "rawExp.airmass",        "<");
Note: See TracChangeset for help on using the changeset viewer.