dltasks module

class dltasks.AddCapability(datalab)[source]

Bases: dltasks.Task

Add a capability to a VOSpace container

run()[source]
class dltasks.Broadcast(datalab)[source]

Bases: dltasks.Task

Broadcast a SAMP message

run()[source]
class dltasks.Copy(datalab)[source]

Bases: dltasks.Task

Copy a file in Data Lab

run()[source]
class dltasks.DataLab[source]

Main class for Data Lab interactions

get(section, param)[source]

Get a value from the configuration file.

save(section, param, value)[source]

Save the configuration file.

class dltasks.Delete(datalab)[source]

Bases: dltasks.Task

Delete files in Data Lab

run()[source]
class dltasks.DropMyDB(datalab)[source]

Bases: dltasks.Task

Drop a user’s MyDB table.

run()[source]
class dltasks.Get(datalab)[source]

Bases: dltasks.Task

Get one or more files from Data Lab.

run()[source]
class dltasks.Launch(datalab)[source]

Bases: dltasks.Task

Launch a plugin in Data Lab

run()[source]
class dltasks.LaunchJob(datalab)[source]

Bases: dltasks.Task

Execute a remote processing job in the Data Lab

getJob(job)[source]
run()[source]
validJob(job)[source]

Bases: dltasks.Task

Link a file in Data Lab

run()[source]
class dltasks.List(datalab)[source]

Bases: dltasks.Task

List files in Data Lab

run()[source]
class dltasks.ListCapability(datalab)[source]

Bases: dltasks.Task

Add a capability to a VOSpace container

run()[source]
class dltasks.ListMyDB(datalab)[source]

Bases: dltasks.Task

List the user’s MyDB tables.

run()[source]
class dltasks.Login(datalab)[source]

Bases: dltasks.Task

Log into the Data Lab

do_login()[source]
login()[source]

Log-in to the Data Lab.

run()[source]

Execute the Login Task.

class dltasks.Logout(datalab)[source]

Bases: dltasks.Task

Logout out of the Data Lab

run()[source]
class dltasks.MkDir(datalab)[source]

Bases: dltasks.Task

Create a directory in Data Lab

run()[source]
class dltasks.Mountvofs(datalab)[source]

Bases: dltasks.Task

Mount a VOSpace via FUSE

run()[source]
class dltasks.Move(datalab)[source]

Bases: dltasks.Task

Move files in Data Lab

run()[source]
class dltasks.Option(name, value, description, display=None, default=None, required=False)[source]

Represents an option

class dltasks.Put(datalab)[source]

Bases: dltasks.Task

Put files into Data Lab.

run()[source]
class dltasks.Query(datalab)[source]

Bases: dltasks.Task

Send a query to a remote query service (OLD VERSION - NOT USED))

dbquery(h, url, token)[source]
httpquery(h, url, token)[source]
ivoquery(h, uri, token, out)[source]
run()[source]
class dltasks.Query2(datalab)[source]

Bases: dltasks.Task

Send a query to a remote query service. [Note: placeholder name until we figure out what to do with the old Query() functionality.]

run()[source]
class dltasks.QueryProfiles(datalab)[source]

Bases: dltasks.Task

List the available Query Manager profiles.

run()[source]
class dltasks.QueryResults(datalab)[source]

Bases: dltasks.Task

Get the async query results.

run()[source]
class dltasks.QueryStatus(datalab)[source]

Bases: dltasks.Task

Get the async query job status.

run()[source]
class dltasks.Receiver(client)[source]

SAMP listener

point_select(private_key, send_id, mtype, params, extra)[source]
receive_notifications(private_key, sender_id, mtype, params, extra)[source]
receiver_call(private_key, sender_id, msg_id, mtype, params, extra)[source]
class dltasks.Resolve(datalab)[source]

Bases: dltasks.Task

Resolve a vos short form identifier – FIXME

run()[source]
class dltasks.RmDir(datalab)[source]

Bases: dltasks.Task

Delete a directory in Data Lab

run()[source]
class dltasks.Schema(datalab)[source]

Bases: dltasks.Task

Print information about data servicce schema

run()[source]
class dltasks.SiaQuery(datalab)[source]

Bases: dltasks.Task

SIA query with an uploaded file

getUID()[source]

Get the UID for this user

run()[source]
class dltasks.Status(datalab)[source]

Bases: dltasks.Task

Status of the Data Lab connection

run()[source]
class dltasks.StorageProfiles(datalab)[source]

Bases: dltasks.Task

List the available Storage Manager profiles.

run()[source]
class dltasks.Tag(datalab)[source]

Bases: dltasks.Task

Tag a file in Data Lab

run()[source]
class dltasks.Task(datalab, name, description)[source]

Superclass to represent a Task

addLogger(logLevel, logFile)[source]

Add a Logger to the Task.

addOption(name, option)[source]

Add an option to the Task.

broadcast(client, messageType, params, app=None)[source]

Broadcast a SAMP message.

getSampConnect()[source]

Get a SAMP listening client connection.

listen(client)[source]

Setup a listener for a specific SAMP message.

report(resp)[source]

Handle call response

run()[source]
setLogger(logLevel=None)[source]

Set the logger to be used.

setOption(name, value)[source]

Set a Task option.

class dltasks.WhoAmI(datalab)[source]

Bases: dltasks.Task

Print the current active user.

run()[source]
dltasks.getUserName(self)[source]

Get the currently logged-in user token. If we haven’t logged in return the anonymous token.

dltasks.getUserToken(self)[source]

Get the currently logged-in user token. If we haven’t logged in return the anonymous token.

dltasks.parseSelf(obj)[source]