Did I find the right examples for you? yes no

All Samples(9)  |  Call(9)  |  Derive(0)  |  Import(0)
We don't care about locking at this point -- so we simply release the
workload immediately...

Questions

. I remember we discussed this previously but I forgot about why we
  we decided to pass IDs instead of objects. Having a syntactic check
  on workload seems ugly and somewhat fragile. I would think a type
  checking would be more robust.
(more...)

src/t/r/troy-0.0.3/troy/workload/workload_manager.py   troy(Download)
 
 
        workload = troy.WorkloadManager.get_workload (workload_id, _manager=self)
        overlay  = troy.OverlayManager .get_overlay  (overlay_id,  _manager=self)
 

src/t/r/troy-0.0.3/troy/plugins/strategy/plugin_strategy_basic_early_binding.py   troy(Download)
 
                troy._logger.info  ("dispatch workload partition 0 (%s)" % partition_id)
                partition = troy.WorkloadManager.get_workload (partition_id)
 
                # throughout this loop, we reflect the workload state as the state
 
                troy._logger.info  ("running workload partition %s" % partition_id)
                partition = troy.WorkloadManager.get_workload (partition_id)
 
                # throughout this loop, we reflect the workload state as the state

src/t/r/troy-0.0.3/troy/planner/planner.py   troy(Download)
 
        # Get the workload from the repo
        workload = troy.WorkloadManager.get_workload(workload_id)
 
        self.timed_component (workload, 'troy.Workload', workload.id)
 
        # Get the workload from the repo
        workload = troy.WorkloadManager.get_workload(workload_id)
 
        self.timed_component (workload, 'troy.Workload', workload.id)

src/t/r/troy-0.0.3/troy/plugins/strategy/plugin_strategy_basic_late_binding.py   troy(Download)
 
                troy._logger.info  ("running workload partition %s" % partition_id)
                partition = troy.WorkloadManager.get_workload (partition_id)
 
                # throughout this loop, we reflect the workload state as the state

src/t/r/troy-0.0.3/troy/plugins/planner_derive/plugin_planner_derive_concurrent.py   troy(Download)
        cores          = 0
        c_partition_id = workload.partitions[0] # max 1
        c_partition    = troy.WorkloadManager.get_workload (c_partition_id)
 
        if 'pilot_size' in self.cfg :

src/t/r/troy-0.0.3/tests/unittests/workload_manager/test_register_workload.py   troy(Download)
    wlid = wl1.id
 
    wl2 = troy.WorkloadManager.get_workload (wlid)
 
    assert wl1 == wl2, "%s == %s" % (wl1, wl2)
 
    troy.WorkloadManager.unregister_workload (wlid)
 
    try :
        wl2 = troy.WorkloadManager.get_workload (wlid)