dl.dltasks module

class dl.dltasks.AddCapability(datalab)

Bases: Task

Add a capability to a VOSpace container

run()

class dl.dltasks.Broadcast(datalab)

Bases: Task

Broadcast a SAMP message

run()

class dl.dltasks.Copy(datalab)

Bases: Task

Copy a file in Data Lab

run()

class dl.dltasks.DataLab

Bases: object

Main class for Data Lab interactions

get(section, param)

Get a value from the configuration file.

save(section, param, value)

Save the configuration file.

class dl.dltasks.Delete(datalab)

Bases: Task

Delete files in Data Lab

run()

class dl.dltasks.DropMyDB(datalab)

Bases: Task

Drop a user’s MyDB table. [DEPRECATED]

run()

class dl.dltasks.Get(datalab)

Bases: Task

Get one or more files from Data Lab.

run()

class dl.dltasks.Init(datalab)

Bases: Task

Print the current service URLS in use.

run()

Initialize the Data Lab configuration.

class dl.dltasks.Launch(datalab)

Bases: Task

Launch a plugin in Data Lab

run()

class dl.dltasks.LaunchJob(datalab)

Bases: Task

Execute a remote processing job in the Data Lab

getJob(job)

run()

validJob(job)

class dl.dltasks.Link(datalab)

Bases: Task

Link a file in Data Lab

run()

class dl.dltasks.List(datalab)

Bases: Task

List files in Data Lab

run()

class dl.dltasks.ListCapability(datalab)

Bases: Task

Add a capability to a VOSpace container

run()

class dl.dltasks.ListMyDB(datalab)

Bases: Task

List the user’s MyDB tables. [DEPRECATED]

run()

class dl.dltasks.Login(datalab)

Bases: Task

Log into the Data Lab

do_login()

login()

Login to the Data Lab.

run()

Execute the Login Task.

class dl.dltasks.Logout(datalab)

Bases: Task

Logout out of the Data Lab

run()

class dl.dltasks.MkDir(datalab)

Bases: Task

Create a directory in Data Lab

run()

class dl.dltasks.Mountvofs(datalab)

Bases: Task

Mount a VOSpace via FUSE

run()

class dl.dltasks.Move(datalab)

Bases: Task

Move files in Data Lab

run()

class dl.dltasks.MyDB_Copy(datalab)

Bases: Task

Copy a user MyDB table.

run()

class dl.dltasks.MyDB_Create(datalab)

Bases: Task

Create a user MyDB table.

run()

class dl.dltasks.MyDB_Drop(datalab)

Bases: Task

Drop a user’s MyDB table.

run()

class dl.dltasks.MyDB_Import(datalab)

Bases: Task

Import data into a user MyDB table.

run()

class dl.dltasks.MyDB_Index(datalab)

Bases: Task

Index data in a user’s MyDB table.

run()

class dl.dltasks.MyDB_Insert(datalab)

Bases: Task

Insert data into a user MyDB table.

run()

class dl.dltasks.MyDB_List(datalab)

Bases: Task

List the user’s MyDB tables.

run()

class dl.dltasks.MyDB_Rename(datalab)

Bases: Task

Rename a user MyDB table.

run()

class dl.dltasks.MyDB_Truncate(datalab)

Bases: Task

Truncate a user MyDB table.

run()

class dl.dltasks.Option(name, value, description, display=None, default=None, required=False)

Bases: object

Represents an option

class dl.dltasks.Put(datalab)

Bases: Task

Put files into Data Lab.

run()

class dl.dltasks.Query(datalab)

Bases: Task

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

dbquery(h, url, token)

httpquery(h, url, token)

ivoquery(h, uri, token, out)

run()

class dl.dltasks.Query2(datalab)

Bases: 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()

class dl.dltasks.QueryProfiles(datalab)

Bases: Task

List the available Query Manager profiles.

run()

class dl.dltasks.QueryResults(datalab)

Bases: Task

Get the async query results.

run()

class dl.dltasks.QueryStatus(datalab)

Bases: Task

Get the async query job status.

run()

class dl.dltasks.Receiver(client)

Bases: object

SAMP listener

point_select(private_key, send_id, mtype, params, extra)

receive_notifications(private_key, sender_id, mtype, params, extra)

receiver_call(private_key, sender_id, msg_id, mtype, params, extra)

class dl.dltasks.Resolve(datalab)

Bases: Task

Resolve a vos short form identifier – FIXME

run()

class dl.dltasks.RmDir(datalab)

Bases: Task

Delete a directory in Data Lab

run()

class dl.dltasks.Schema(datalab)

Bases: Task

Print information about data servicce schema

run()

class dl.dltasks.Services(datalab)

Bases: Task

Print the available data services.

run()

class dl.dltasks.SiaQuery(datalab)

Bases: Task

SIA query with an uploaded file

getUID()

Get the UID for this user

run()

class dl.dltasks.Status(datalab)

Bases: Task

Status of the Data Lab connection

run()

class dl.dltasks.StorageProfiles(datalab)

Bases: Task

List the available Storage Manager profiles.

run()

class dl.dltasks.SvcURLs(datalab)

Bases: Task

Print the current service URLS in use.

run()

class dl.dltasks.Tag(datalab)

Bases: Task

Tag a file in Data Lab

run()

class dl.dltasks.Task(datalab, name, description)

Bases: object

Superclass to represent a Task

addLogger(logLevel, logFile)

Add a Logger to the Task.

addOption(name, option)

Add an option to the Task.

addStdOptions()

broadcast(client, messageType, params, app=None)

Broadcast a SAMP message.

getSampConnect()

Get a SAMP listening client connection.

listen(client)

Setup a listener for a specific SAMP message.

report(resp)

Handle call response

run()

setLogger(logLevel=None)

Set the logger to be used.

setOption(name, value)

Set a Task option.

class dl.dltasks.Version(datalab)

Bases: Task

Print the task version.

run()

class dl.dltasks.WhoAmI(datalab)

Bases: Task

Print the current active user.

run()

dl.dltasks.getUserName(self)

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

dl.dltasks.getUserToken(self)

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

dl.dltasks.parseSelf(obj)