execDef.spawn("gavo --ui stingy imp -c lightmeter/q add".split())
mod = utils.loadPythonModule(rd.getAbsPath("bin/coverageplot"))[0]
mod.makePlot()
stationId = os.path.split(os.path.split(sourceToken)[0])[1]
if re.match("[0-9]+$", stationId):
raise base.SkipThis("Archive directory")
try:
with base.getTableConn() as conn:
stationPars = list(conn.query(
"SELECT calibA, calibB, calibC, calibD, timeCorrection"
" FROM lightmeter.stations"
" WHERE stationId=%(stationId)s", locals()))[0]
calibA, calibB, calibC, calibD, timeCorrection = stationPars
except IndexError:
raise base.ValidationError("No station data for %s. Import"
" stationsdata first."
%stationId, "stationId", stationId)
if calibA is None:
raise base.SkipThis("No calibration for %s."%stationId)
srcKey = "/".join(utils.getRelativePath(sourceToken,
base.getConfig("inputsDir"), liberalChars=True).split("/")[2:])
return locals()
baseJD = dateTimeToJdn(
datetime.datetime.combine(inPars["epoch"], inPars["time"]))
dt = int(inPars["within"])*60/24./3600.
yield "epoch BETWEEN %%(%s)s AND %%(%s)s"%(
base.getSQLKey("epoch", baseJD-dt, outPars),
base.getSQLKey("epoch", baseJD+dt, outPars))
ik = inputKeys[0]
yield "epoch>%%(%s)s"%base.getSQLKey(ik.name,
stc.dateTimeToJdn(datetime.datetime.now())-inPars[ik.name],
outPars)
self.assertHasStrings("Directory listing", "[Directory]")
self.assertHasStrings("File zw.txt.gz uploaded, 65 bytes.")
self.assertHasStrings("File zw.txt.gz already exists.",
"overwrite it, contact")
self.assertHasStrings("File zw.txt.gz removed.")
self.assertHasStrings(
"'zw.txt.gz' does not exist and thus cannot be deleted.")
self.assertHasStrings("File test.zip uploaded, 14 bytes.")
self.assertHasStrings("could not be written: a.txt, b.txt;")
self.assertHasStrings("a.txt.gz removed")
self.assertHasStrings("b.txt.gz removed")
self.assertHasStrings("log(Flux)", "5.5435")
self.assertHasStrings("404", "No such upload facility")