Trees       Indices       Help   
Ganeti
Package ganeti :: Package client :: Module gnt_job
[hide private]
[frames] | no frames]

Module gnt_job

source code

Job related commands

Functions [hide private]
 
_FormatStatus(value)
Formats a job status.		 source code
 
_FormatSummary(value)
Formats a job's summary.		 source code
 
_ParseJobIds(args)
Parses a list of string job IDs into integers.		 source code
int
ListJobs(opts, args)
List the jobs		 source code
int
ListJobFields(opts, args)
List job fields.		 source code
int
ArchiveJobs(opts, args)
Archive jobs.		 source code
int
AutoArchiveJobs(opts, args)
Archive jobs based on age.		 source code
int
_MultiJobAction(opts, args, cl, stdout_fn, ask_fn, question, action_fn)
Applies a function to multipe jobs.		 source code
int
CancelJobs(opts, args, cl=None, _stdout_fn=ToStdout, _ask_fn=AskUser)
Cancel not-yet-started jobs.		 source code
int
ChangePriority(opts, args)
Change priority of jobs.		 source code
 
_ListOpcodeTimestamp(name, ts, container)
Adds the opcode timestamp to the given container.		 source code
 
_CalcDelta(from_ts, to_ts)
Calculates the delta between two timestamps.		 source code
 
_ListJobTimestamp(name, ts, container, prior_ts=None)
Adds the job timestamp to the given container.		 source code
int
ShowJobs(opts, args)
Show detailed information about jobs.		 source code
int
WatchJob(opts, args)
Follow a job and print its output as it arrives.		 source code
int
WaitJob(opts, args)
Wait for a job to finish, not producing any output.		 source code
 
Main() source code
Variables [hide private]
  _LIST_DEF_FIELDS = ["id", "status", "summary"]
default list of fields for ListJobs
  _USER_JOB_STATUS = {constants.JOB_STATUS_QUEUED: "queued", con...
map converting the job status contants to user-visible names
  _JOB_LIST_FORMAT = {"status":(_FormatStatus, False), "summary"...
  _KILL_OPT = cli_option("--kill", default= False, action= "stor...
  _YES_DOIT_OPT = cli_option("--yes-do-it", "--ya-rly", dest= "y...
  _PENDING_OPT = cli_option("--pending", default= None, action= ...
  _RUNNING_OPT = cli_option("--running", default= None, action= ...
  _ERROR_OPT = cli_option("--error", default= None, action= "sto...
  _FINISHED_OPT = cli_option("--finished", default= None, action...
  _ARCHIVED_OPT = cli_option("--archived", default= False, actio...
  _QUEUED_OPT = cli_option("--queued", default= None, action= "s...
  _WAITING_OPT = cli_option("--waiting", default= None, action= ...
  commands = {"list":(ListJobs, [ArgJobId()], [NOHDR_OPT, SEP_OP...
  aliases = {"show": "info",}
dictionary with aliases for commands

Imports: OOB_TIMEOUT_OPT, MAC_PREFIX_OPT, IPOLICY_STD_SPECS_OPT, SHUTDOWN_TIMEOUT_OPT, ARGS_ONE_GROUP, ARGS_MANY_NODES, IGNORE_REMOVE_FAILURES_OPT, NWSYNC_OPT, IDENTIFY_DEFAULTS_OPT, FormatParamsDictInfo, FormatTimestamp, DEFAULT_IALLOCATOR_PARAMS_OPT, RAPI_CERT_OPT, AUTO_PROMOTE_OPT, RESERVED_LVS_OPT, FormatPolicyInfo, GLOBAL_SHARED_FILEDIR_OPT, MAINTAIN_NODE_HEALTH_OPT, shlex, DRY_RUN_OPT, ARGS_MANY_FILTERS, NIC_PARAMS_OPT, PrintIPolicyCommand, AUTO_REPLACE_OPT, compat, USEUNITS_OPT, NOMODIFY_ETCHOSTS_OPT, VERBOSE_OPT, NEW_NODE_CERT_OPT, HOTPLUG_OPT, GenerateTable, ARGS_ONE_NODE, ALLOW_FAILOVER_OPT, NOSTART_OPT, INSTANCE_COMMUNICATION_NETWORK_OPT, SPECS_NIC_COUNT_OPT, objects, MASTER_NETMASK_OPT, SPICE_CERT_OPT, INTERVAL_OPT, ToStdout, OSPARAMS_OPT, StringIO, RQL_OPT, StdioJobPollReportCb, CAPAB_MASTER_OPT, MODIFY_ETCHOSTS_OPT, SPECS_MEM_SIZE_OPT, TAG_SRC_OPT, NODEGROUP_OPT, SYNC_OPT, ONLINE_INST_OPT, TableColumn, NONPLUS1_OPT, NEW_SSH_KEY_OPT, JobSubmittedException, ARGS_ONE_OS, PollJob, NETWORK_OPT, TIMEOUT_OPT, ON_SECONDARY_OPT, MIGRATION_MODE_OPT, REMOVE_INSTANCE_OPT, SEQUENTIAL_OPT, ZEROING_TIMEOUT_PER_MIB_OPT, DISK_TEMPLATE_OPT, REASON_OPT, NO_INSTALL_OPT, DEFAULT_IALLOCATOR_OPT, NOCONFLICTSCHECK_OPT, SubmitOpCode, LONG_SLEEP_OPT, JobPollReportCbBase, ArgNode, CP_SIZE_OPT, ALLOCATABLE_OPT, PREALLOC_WIPE_DISKS_OPT, IPOLICY_VCPU_RATIO, GetClient, EXT_PARAMS_OPT, ENABLED_HV_OPT, PrintGenericInfo, FIELDS_OPT, GLOBAL_GLUSTER_FILEDIR_OPT, INCLUDEDEFAULTS_OPT, ARGS_ONE_INSTANCE, IPOLICY_SPINDLE_RATIO, IPOLICY_DISK_TEMPLATES, JobPollCbBase, NO_REMEMBER_OPT, NOVOTING_OPT, SPECS_CPU_COUNT_OPT, netutils, SECONDARY_IP_OPT, NETWORK6_OPT, GenericPollJob, ABSOLUTE_OPT, READD_OPT, BACKEND_OPT, FormatTable, FILESTORE_DIR_OPT, OSPARAMS_PRIVATE_OPT, NONAMECHECK_OPT, NODE_POWERED_OPT, TAG_ADD_OPT, ArgOs, HVLIST_OPT, CONFIRM_OPT, ALL_OPT, CalculateOSNames, ENABLED_USER_SHUTDOWN_OPT, FAILURE_ONLY_OPT, ENABLED_DISK_TEMPLATES_OPT, SUBMIT_OPT, GATEWAY_OPT, ADD_UIDS_OPT, logging, IPOLICY_STD_SPECS_STR, NODE_PARAMS_OPT, SPLIT_ISPECS_OPTS, GLOBAL_FILEDIR_OPT, NOSHUTDOWN_OPT, TISPECS_CLUSTER_TYPES, NET_OPT, IGNORE_FAILURES_OPT, SRC_DIR_OPT, REMOVE_UIDS_OPT, HYPERVISOR_OPT, MC_OPT, NODE_FORCE_JOIN_OPT, IGNORE_CONSIST_OPT, RunWhileDaemonsStopped, STATIC_OPT, NONLIVE_OPT, DISK_OPT, REMOVE_RESERVED_IPS_OPT, COMPRESS_OPT, FILESTORE_DRIVER_OPT, CreateIPolicyFromOpts, ArgJobId, ConfirmOperation, HELPER_SHUTDOWN_TIMEOUT_OPT, SHOWCMD_OPT, ArgGroup, OFFLINE_INST_OPT, ListTags, NEW_CLUSTER_DOMAIN_SECRET_OPT, COMMON_OPTS, ParseTimespec, pathutils, ZERO_FREE_SPACE_OPT, ArgFilter, RUNTIME_MEM_OPT, HID_OS_OPT, NOHDR_OPT, ZEROING_IMAGE_OPT, TISPECS_GROUP_TYPES, VG_NAME_OPT, SubmitOpCodeToDrainedQueue, IALLOCATOR_OPT, STARTUP_PAUSED_OPT, DISKIDX_OPT, TO_GROUP_OPT, POWER_DELAY_OPT, OPT_COMPL_ALL, IGNORE_SECONDARIES_OPT, GenericList, CLEANUP_OPT, GetNodeUUIDs, ssh, HOTPLUG_IF_POSSIBLE_OPT, COMMON_CREATE_OPTS, GenericInstanceCreate, ArgChoice, CAPAB_VM_OPT, NODE_PLACEMENT_OPT, FixHvParams, ToStderr, ganeti, ArgExtStorage, FORCE_VARIANT_OPT, AskUser, CLUSTER_DOMAIN_SECRET_OPT, DISK_STATE_OPT, TitledHelpFormatter, ARGS_NONE, IGNORE_SIZE_OPT, SetGenericOpcodeOpts, OS_SIZE_OPT, ARGS_ONE_FILTER, ParseFields, HV_STATE_OPT, ArgNetwork, itertools, SRC_NODE_OPT, NOSSH_KEYCHECK_OPT, INSTANCE_POLICY_OPTS, MASTER_NETDEV_OPT, NOMODIFY_SSH_SETUP_OPT, INSTANCE_COMMUNICATION_OPT, IGNORE_OFFLINE_OPT, IGNORE_ERRORS_OPT, EARLY_RELEASE_OPT, FormatResultError, SplitNodeOption, NEW_SPICE_CERT_OPT, SPECS_DISK_COUNT_OPT, FORCE_FAILOVER_OPT, PRIMARY_ONLY_OPT, RemoveTags, NEW_PRIMARY_OPT, ArgInstance, COMMIT_OPT, MAX_TRACK_OPT, NONICS_OPT, SELECT_OS_OPT, FORCE_OPT, PRINT_JOBID_OPT, PRIORITY_OPT, DRAINED_OPT, IGNORE_SOFT_ERRORS_OPT, VERIFY_CLUTTER_OPT, PRIMARY_IP_VERSION_OPT, NODEGROUP_OPT_NAME, GetNodesSshPorts, SHOW_MACHINE_OPT, sys, FormatQueryResult, HELPER_STARTUP_TIMEOUT_OPT, OFFLINE_OPT, YES_DOIT_OPT, NEW_CONFD_HMAC_KEY_OPT, UsesRPC, ZEROING_TIMEOUT_FIXED_OPT, UIDPOOL_OPT, ALLOC_POLICY_OPT, ArgUnknown, ERROR_CODES_OPT, SPECS_DISK_SIZE_OPT, ARGS_ONE_NETWORK, DEBUG_SIMERR_OPT, textwrap, SUBMIT_OPTS, ROMAN_OPT, ARGS_MANY_NETWORKS, rpcerr, SEP_OPT, USE_EXTERNAL_MIP_SCRIPT, rpc, TRANSPORT_COMPRESSION_OPT, JobExecutor, SINGLE_NODE_OPT, INSTALL_IMAGE_OPT, SPICE_CACERT_OPT, OSPARAMS_SECRET_OPT, cli_option, HVOPTS_OPT, NEW_RAPI_CERT_OPT, ArgHost, GenericListFields, ParseNicOption, ArgCommand, DEBUG_OPT, ON_PRIMARY_OPT, NEW_CLUSTER_CERT_OPT, AddTags, RunWhileClusterStopped, BLK_OS_OPT, ENABLED_DATA_COLLECTORS_OPT, os, OS_OPT, IGNORE_HVVERSIONS_OPT, USE_REPL_NET_OPT, SendJob, opcodes, errno, REBOOT_TYPE_OPT, ToStdoutAndLoginfo, IGNORE_IPOLICY_OPT, GATEWAY6_OPT, FORTHCOMING_OPT, SECONDARY_ONLY_OPT, GetOnlineNodes, NODE_LIST_OPT, NOIPCHECK_OPT, IPOLICY_BOUNDS_SPECS_STR, DRBD_HELPER_OPT, COMPRESSION_TOOLS_OPT, OptionParser, ARGS_MANY_GROUPS, FormatLogMessage, GenericMain, ArgFile, WFSYNC_OPT, NORUNTIME_CHGS_OPT, ADD_RESERVED_IPS_OPT, ARGS_MANY_INSTANCES, FORCE_FILTER_OPT, FormatError, ArgSuggest, SubmitOrSend, NEW_SECONDARY_OPT, DISK_PARAMS_OPT, DST_NODE_OPT, time, FeedbackFnJobPollReportCb, serializer, constants, errors, utils, cli, qlang


Function Details [hide private]

_FormatSummary(value)

source code 

Formats a job's summary. Takes possible non-ascii encoding into account.

_ParseJobIds(args)

source code 

Parses a list of string job IDs into integers.

Parameters:
  • args - list of strings
Returns:
list of integers
Raises:

ListJobs(opts, args)

source code 

List the jobs

Parameters:
  • opts - the command line options selected by the user
  • args (list) - should be an empty list
Returns: int
the desired exit code

ListJobFields(opts, args)

source code 

List job fields.

Parameters:
  • opts - the command line options selected by the user
  • args (list) - fields to list, or empty for all
Returns: int
the desired exit code

ArchiveJobs(opts, args)

source code 

Archive jobs.

Parameters:
  • opts - the command line options selected by the user
  • args (list) - should contain the job IDs to be archived
Returns: int
the desired exit code

AutoArchiveJobs(opts, args)

source code 

Archive jobs based on age.

This will archive jobs based on their age, or all jobs if a 'all' is passed.

Parameters:
  • opts - the command line options selected by the user
  • args (list) - should contain only one element, the age as a time spec that can be parsed by ganeti.cli.ParseTimespec or the keyword all, which will cause all jobs to be archived
Returns: int
the desired exit code

_MultiJobAction(opts, args, cl, stdout_fn, ask_fn, question, action_fn)

source code 

Applies a function to multipe jobs.

Parameters:
  • opts - Command line options
  • args (list) - Job IDs
Returns: int
Exit code

CancelJobs(opts, args, cl=None, _stdout_fn=ToStdout, _ask_fn=AskUser)

source code 

Cancel not-yet-started jobs.

Parameters:
  • opts - the command line options selected by the user
  • args (list) - should contain the job IDs to be cancelled
Returns: int
the desired exit code

ChangePriority(opts, args)

source code 

Change priority of jobs.

Parameters:
  • opts - Command line options
  • args (list) - Job IDs
Returns: int
Exit code

_ListJobTimestamp(name, ts, container, prior_ts=None)

source code 

Adds the job timestamp to the given container.

Parameters:
  • prior_ts - The timestamp used to calculate the amount of time that passed since the given timestamp.

ShowJobs(opts, args)

source code 

Show detailed information about jobs.

Parameters:
  • opts - the command line options selected by the user
  • args (list) - should contain the job IDs to be queried
Returns: int
the desired exit code

WatchJob(opts, args)

source code 

Follow a job and print its output as it arrives.

Parameters:
  • opts - the command line options selected by the user
  • args (list) - Contains the job ID
Returns: int
the desired exit code

WaitJob(opts, args)

source code 

Wait for a job to finish, not producing any output.

Parameters:
  • opts - the command line options selected by the user
  • args (list) - Contains the job ID
Returns: int
the desired exit code

Variables Details [hide private]

_USER_JOB_STATUS

map converting the job status contants to user-visible names

Value:
{constants.JOB_STATUS_QUEUED: "queued", constants.JOB_STATUS_WAITING: \
"waiting", constants.JOB_STATUS_CANCELING: "canceling", constants.JOB_\
STATUS_RUNNING: "running", constants.JOB_STATUS_CANCELED: "canceled", \
constants.JOB_STATUS_SUCCESS: "success", constants.JOB_STATUS_ERROR: "\
error",}

_JOB_LIST_FORMAT

Value:
{"status":(_FormatStatus, False), "summary":(_FormatSummary, False),}

_KILL_OPT

Value:
cli_option("--kill", default= False, action= "store_true", dest= "kill\
", help= "Kill running jobs with SIGKILL")

_YES_DOIT_OPT

Value:
cli_option("--yes-do-it", "--ya-rly", dest= "yes_do_it", help= "Really\
 use --kill", action= "store_true")

_PENDING_OPT

Value:
cli_option("--pending", default= None, action= "store_const", dest= "s\
tatus_filter", const= constants.JOBS_PENDING, help= "Select jobs pendi\
ng execution or being cancelled")

_RUNNING_OPT

Value:
cli_option("--running", default= None, action= "store_const", dest= "s\
tatus_filter", const= frozenset([constants.JOB_STATUS_RUNNING,]), help\
= "Show jobs currently running only")

_ERROR_OPT

Value:
cli_option("--error", default= None, action= "store_const", dest= "sta\
tus_filter", const= frozenset([constants.JOB_STATUS_ERROR,]), help= "S\
how failed jobs only")

_FINISHED_OPT

Value:
cli_option("--finished", default= None, action= "store_const", dest= "\
status_filter", const= constants.JOBS_FINALIZED, help= "Show finished \
jobs only")

_ARCHIVED_OPT

Value:
cli_option("--archived", default= False, action= "store_true", dest= "\
archived", help= "Include archived jobs in list (slow and expensive)")

_QUEUED_OPT

Value:
cli_option("--queued", default= None, action= "store_const", dest= "st\
atus_filter", const= frozenset([constants.JOB_STATUS_QUEUED,]), help= \
"Select queued jobs only")

_WAITING_OPT

Value:
cli_option("--waiting", default= None, action= "store_const", dest= "s\
tatus_filter", const= frozenset([constants.JOB_STATUS_WAITING,]), help\
= "Select waiting jobs only")

commands

Value:
{"list":(ListJobs, [ArgJobId()], [NOHDR_OPT, SEP_OPT, FIELDS_OPT, VERB\
OSE_OPT, FORCE_FILTER_OPT, _PENDING_OPT, _RUNNING_OPT, _ERROR_OPT, _FI\
NISHED_OPT, _ARCHIVED_OPT], "[job_id ...]", "Lists the jobs and their \
status. The available fields can be shown" " using the \"list-fields\"\
 command (see the man page for details)." " The default field list is \
(in order): %s." % utils.CommaJoin(_LIST_DEF_FIELDS)), "list-fields":(\
ListJobFields, [ArgUnknown()], [NOHDR_OPT, SEP_OPT], "[fields...]", "L\
ists all available fields for jobs"), "archive":(ArchiveJobs, [ArgJobI\
...

   Trees       Indices       Help   
Ganeti
Generated by Epydoc 3.0.1 on Mon Aug 22 11:13:08 2016 http://epydoc.sourceforge.net