pdg.job package¶
Submodules¶
pdg.job.callbackserver module¶
-
class
pdg.job.callbackserver.CallbackServerMixin(local_only)¶ -
isCallbackServerRunning()¶
-
logEvent(client_address, event)¶ Called when an event is recieved from the callback server handler.
-
startCallbackServer()¶ Starts the socket server and server thread for communicating with jobs.
-
stopCallbackServer()¶ Stops the server thread and unbinds the socket.
-
workItemResultServerAddr()¶
-
-
class
pdg.job.callbackserver.CanceledEvent(item_name, index, extra)¶ Bases:
tuple-
extra¶ Alias for field number 2
-
index¶ Alias for field number 1
-
item_name¶ Alias for field number 0
-
-
class
pdg.job.callbackserver.CustomTCPServer(server_address, request_class, bind_and_activate=True)¶ Bases:
SocketServer.TCPServer-
allow_reuse_address= True¶
-
request_queue_size= 512¶
-
-
class
pdg.job.callbackserver.FailedEvent(item_name, index, extra)¶ Bases:
tuple-
extra¶ Alias for field number 2
-
index¶ Alias for field number 1
-
item_name¶ Alias for field number 0
-
-
class
pdg.job.callbackserver.ResultDataEvent(item_name, index, result_data, result_data_tag, hash_code, extra)¶ Bases:
tuple-
extra¶ Alias for field number 5
-
hash_code¶ Alias for field number 4
-
index¶ Alias for field number 1
-
item_name¶ Alias for field number 0
-
result_data¶ Alias for field number 2
-
result_data_tag¶ Alias for field number 3
-
-
class
pdg.job.callbackserver.StartCookEvent(item_name, index, extra)¶ Bases:
tuple-
extra¶ Alias for field number 2
-
index¶ Alias for field number 1
-
item_name¶ Alias for field number 0
-
-
class
pdg.job.callbackserver.SuccessEvent(item_name, index, cook_duration, extra)¶ Bases:
tuple-
cook_duration¶ Alias for field number 2
-
extra¶ Alias for field number 3
-
index¶ Alias for field number 1
-
item_name¶ Alias for field number 0
-
-
class
pdg.job.callbackserver.WorkitemResultServerHandler(request, client_address, server)¶ Bases:
SocketServer.StreamRequestHandlerNon-threaded handler for workitem results. We receive results from workitems with the following syntax: Simplified: <name [string]>;<sub index [int]>;<status [‘S’;<duration>|’C’|’F’|’D’|’I’|B;<result_data>;<data_tag>;<hash_code>’]>
Extended: ‘’+‘1 byte version’
Version 0x00: Protobuf 1 Protobuf 1 uses a proto file to serialize all messages. <packed uint64 length><protobuf>..-
EXTENDED_MAGIC= 128¶
-
VER_JSON_1= 1¶
-
VER_PROTOBUF_1= 0¶
-
handle()¶ Called to handle incoming data.
-
handle_extended(alldata)¶ Handle extended protocol
-
handle_simplified(alldata)¶ Handle simplified text-based protocol. This is a printable, line-oriented format
-
parse_json(payloadview)¶
-
parse_protobuf(payload)¶
-
parse_simplified_payload(item_name, sub_index, status, tokens)¶
-
-
pdg.job.callbackserver.add_event_listener(context, listener_fn)¶ Set the event listener for workitem events in the given context
pdg.job.changelist module¶
pdg.job.ffmpeg module¶
pdg.job.imagemagick module¶
pdg.job.jsondata module¶
pdg.job.mantrarender module¶
pdg.job.parmset_pb2 module¶
pdg.job.rop module¶
-
class
pdg.job.rop.BakeTextureCooker¶ Bases:
pdg.job.rop.RopCooker-
cookBatchFrames(node_path, top_path, item_name, server, start, end, inc)¶
-
cookSingleFrame(node_path, top_path, item_name, server, start, end, inc, tileix)¶
-
-
class
pdg.job.rop.GamesBakerCooker¶ Bases:
pdg.job.rop.RopCooker-
cookBatchFrames(node_path, top_path, item_name, server, start, end, inc)¶
-
cookSingleFrame(node_path, top_path, item_name, server, start, end, inc, tileix)¶
-
-
class
pdg.job.rop.IndirectRopCooker(path)¶ Bases:
pdg.job.rop.RopCooker
-
class
pdg.job.rop.RopCooker¶ -
cookBatchFrames(node_path, top_path, item_name, server, start, end, inc)¶
-
cookSingleFrame(node_path, top_path, item_name, server, start, end, inc, tileix)¶
-
-
pdg.job.rop.applyParmSet(proto_path, verbose=True)¶ Apply a parmset protobuf file to the current HIP session. Used when rop.py is invoked with –parmset option.
-
pdg.job.rop.createParmSet(node_path, proto_path)¶ Creates a parmset protobuf file based on scanning the given TOP node_path for parms with python expressions. Any such parms are evaluated with the current evaluation context and the resulting value is serialized along with the parm path. This is used internally by RopFetch.
-
pdg.job.rop.filterOutputAssets(assets)¶ mantra filter callback function
-
pdg.job.rop.initDistSim(control_path, tracker_ip, tracker_port, slice_num, slice_type, slice_divs)¶
pdg.job.shotgunclient module¶
-
pdg.job.shotgunclient.trusted_loads(value)¶ Reverse operation of trusted_dumps.
NOTE: This function should only be used for TRUSTED data. We trust whatever Shotgun returns.