Changeset View
Changeset View
Standalone View
Standalone View
wallace/__init__.py
Show First 20 Lines • Show All 280 Lines • ▼ Show 20 Lines | def pickup_spool_messages(self, sync=False): | ||||
for filename in files: | for filename in files: | ||||
messages.append((root, filename)) | messages.append((root, filename)) | ||||
for root, filename in messages: | for root, filename in messages: | ||||
filepath = os.path.join(root, filename) | filepath = os.path.join(root, filename) | ||||
try: | try: | ||||
# ignore calls on too young files | |||||
if os.stat(filepath).st_mtime + 150 > time.time(): | if os.stat(filepath).st_mtime + 150 > time.time(): | ||||
log.debug("Skipping %s" % (filepath), level=8) | log.debug("File not more than 150s old. Skipping %s" % (filepath), level=8) | ||||
continue | continue | ||||
except: | # ignore calls on lock files | ||||
if '/locks/' in filepath: | |||||
log.debug("File is in locks directory. Skipping %s" % (filepath), level=8) | |||||
continue | |||||
except Exception, errmsg: | |||||
log.error("Error: %s. Skipping %s" % (errmsg, filepath)) | |||||
continue | continue | ||||
if not root == pickup_path: | if not root == pickup_path: | ||||
module = os.path.dirname(root).replace(pickup_path, '') | module = os.path.dirname(root).replace(pickup_path, '') | ||||
# Compare uppercase status (specifically, DEFER) with | # Compare uppercase status (specifically, DEFER) with | ||||
# lowercase (plugin names). | # lowercase (plugin names). | ||||
# | # | ||||
▲ Show 20 Lines • Show All 241 Lines • Show Last 20 Lines |