Did I find the right examples for you? yes no

All Samples(61)  |  Call(61)  |  Derive(0)  |  Import(0)
Log 'msg % args' with severity 'INFO'.

To pass exception information, use the keyword argument exc_info with
a true value, e.g.

logger.info("Houston, we have a %s", "interesting problem", exc_info=1)

src/t/r/troy-0.0.3/troy/plugins/strategy/plugin_strategy_basic_early_binding.py   troy(Download)
            # stratey.
 
            troy._logger.info ('apply early binding strategy to workload %s!' % workload_id)
            workload = workload_mgr.get_workload (workload_id)
 
            for partition_id in workload.partitions[:1] :
 
                troy._logger.info  ("dispatch workload partition 0 (%s)" % partition_id)
                partition = troy.WorkloadManager.get_workload (partition_id)
 
 
                if partition.state == troy.DONE :
                    troy._logger.info  ("partition %s done" % partition.id)
                else :
                    troy._logger.error ("partition %s failed - abort" % partition.id)
            for partition_id in workload.partitions[1:] :
 
                troy._logger.info  ("running workload partition %s" % partition_id)
                partition = troy.WorkloadManager.get_workload (partition_id)
 
 
                if partition.state == troy.DONE :
                    troy._logger.info  ("partition done")
                else :
                    troy._logger.error ("partition failed - abort")

src/t/r/troy-0.0.3/troy/plugins/strategy/plugin_strategy_basic_late_binding.py   troy(Download)
        try :
 
            troy._logger.info ('troy default strategy : strategize workload %s!' % workload_id)
            workload = workload_mgr.get_workload (workload_id)
 
            for partition_id in workload.partitions :
 
                troy._logger.info  ("running workload partition %s" % partition_id)
                partition = troy.WorkloadManager.get_workload (partition_id)
 
 
                if partition.state == troy.DONE :
                    troy._logger.info  ("partition %s done" % partition.id)
                else :
                    troy._logger.error ("partition %s failed - abort" % partition.id)
 
 
            troy._logger.info ("all partition done (%s)" % workload.state)
 
            overlay_mgr.cancel_overlay (overlay.id)

src/t/r/troy-0.0.3/troy/plugins/workload_dispatcher/plugin_workload_dispatcher_sagapilot.py   troy(Download)
        else :
            troy._logger.error ("No COORDINATION_URL set for sagapilot backend")
            troy._logger.info  ("example: export COORDINATION_URL=redis://<pass>@gw68.quarry.iu.teragrid.org:6379")
            troy._logger.info  ("Contact Radica@Ritgers for the redis password")
            raise RuntimeError ("Cannot use sagapilot backend - no COORDINATION_URL -- see debug log for details")
                # instance from a cache, so should not cost too much.
                pilot      = troy.Pilot (self.session, pilot_id, _instance_type='sagapilot')
                troy._logger.info ('workload dispatch : dispatch %-18s to %s' \
                                % (uid, pilot._get_instance('sagapilot')[1]))
 
        if  info['state'] == FAILED :
            troy._logger.error ('CU %s failed' % unit.id)
            troy._logger.info ('log: \n----\n%s\n---\n' % info['log'])
            troy._logger.info ('stderr: \n----\n%s\n---\n' % info['stderr'])
            troy._logger.info ('stdout: \n----\n%s\n---\n' % info['stdout'])

src/t/r/troy-0.0.3/troy/plugins/overlay_provisioner/plugin_overlay_provisioner_bigjob.py   troy(Download)
        else :
            troy._logger.error ("No COORDINATION_URL set for bigjob backend")
            troy._logger.info  ("example: export COORDINATION_URL=redis://<pass>@gw68.quarry.iu.teragrid.org:6379")
            troy._logger.info  ("Contact Radica@Ritgers for the redis password")
            raise RuntimeError ("Cannot use bigjob backend - no COORDINATION_URL -- see debug log for details")
                                      native_id     = bj_pilot.get_url ())
 
            troy._logger.info ('overlay  provision: provision pilot  %s : %s ' \
                            % (troy_pilot, troy_pilot._get_instance ('bigjob')))
 

src/t/r/troy-0.0.3/troy/plugins/overlay_provisioner/plugin_overlay_provisioner_sagapilot.py   troy(Download)
        else :
            troy._logger.error ("No COORDINATION_URL set for sagapilot backend")
            troy._logger.info  ("example: export COORDINATION_URL=redis://<pass>@gw68.quarry.iu.teragrid.org:6379")
            troy._logger.info  ("Contact Radica@Ritgers for the redis password")
            raise RuntimeError ("Cannot use sagapilot backend - no COORDINATION_URL -- see debug log for details")
            pilot_descr.sandbox  = "%s/troy_agents/" % troy_pilot.description['home']
 
            troy._logger.info ('overlay  provision: provision   pilot  %s : %s ' \
                            % (pid, troy_pilot.resource))
 
                                      native_id     = [sp_um.uid, sp_pm.uid, sp_pilot.uid])
 
            troy._logger.info ('overlay  provision: provisioned pilot  %s : %s (%s)' \
                            % (troy_pilot, 
                               troy_pilot._get_instance ('sagapilot')[2], 

src/t/r/troy-0.0.3/troy/utils/misc.py   troy(Download)
                try :
                    cfg_dict = ru.read_json (cfg_file)
                    troy._logger.info ("reading  config in %s" % cfg_file)
                except Exception as e :
                    troy._logger.critical ("skipping config in %s (%s)" % (cfg_file, e))

src/t/r/troy-0.0.3/troy/bin/nestor_skeleton.py   troy(Download)
            # wait for workload to reach a final state
            while workload.state not in [troy.DONE, troy.FAILED]:
                troy._logger.info ("whats up, buddy? (workload state: %s)" % workload.state)
                time.sleep(1)
 
            troy._logger.info ("ok, buddy, lets see what you got (workload state: %s)" % workload.state)
 
            if  workload.state != troy.DONE :
                troy._logger.info  ("workload failed!")
                raise RuntimeError ("workload failed!")
 
            troy._logger.info ("workload done")
 
        troy._logger.info ("all workloads done")

src/t/r/troy-0.0.3/troy/plugins/planner_derive/plugin_planner_derive_concurrent.py   troy(Download)
            # task concurrency in %
            concurrency  = int(self.cfg.get ('concurrency', 100))
            troy._logger.info ("planner uses concurrency of %d%%" % concurrency)
 
            # count tasks / concurrent tasks / sequential tasks in workload
 
 
            troy._logger.info ("created %d workload partitions" % len(workload.partitions))
 
 
        ovl_descr = troy.OverlayDescription ({'cores' : cores})
 
        troy._logger.info ("planner  derive ol: derive overlay for workload: %s" % ovl_descr)
 
        return ovl_descr

src/t/r/troy-0.0.3/troy/plugins/planner_derive/plugin_planner_derive_bundles.py   troy(Download)
        #                             'password' 'key_filename', 'h_flag' }
 
        troy._logger.info('Initializing Bundle Manager')
 
        self.bm = BundleManager()
            })
 
        troy._logger.info('planner derive ol: derive overlay for workload: '
                          '%s' % ovl_descr)
 

src/t/r/troy-0.0.3/troy/session.py   troy(Download)
        session_id_stub = self.cfg.get  ("session_id", 'session.')
        self.id         = ru.generate_id (session_id_stub, mode=ru.ID_UNIQUE)
        troy._logger.info ("session id: %s" % self.id)
 
        # and initialize the inherited saga session

  1 | 2 | 3 | 4  Next