# Create torrent file.
bt.create_torrent(transcode_config['output_file'])
- # The torrent file is created in the same directory with the
- # source file. Move it to the torrents directory.
- shutil.move(transcode_config['output_file'] + '.tstream', \
- config.TORRENTS_PATH)
-
output_file = transcode_config['output_file'] + '.tstream'
output_file = output_file[(output_file.rindex('/') + 1):]
+
+ # The torrent file is created in the same directory with the
+ # source file. Move it to the torrents directory.
+ #if not os.path.exists(
+ # os.path.join(output_file, config.TORRENTS_PATH)):
+ try:
+ shutil.move(transcode_config['output_file'] + '.tstream', \
+ config.TORRENTS_PATH)
+ except:
+ pass
# * SEED TORRENTS
Server.bit_torrent.start_torrent( \
for f in files:
os.unlink(os.path.join(path, f))
- def notify_completion(self):
+ def notify_completion(self, code):
logger.log_msg('#%s: notifying web server about the job completion...'\
% self.job_id)
- f = urllib.urlopen(config.WS_COMPLETION)
+ if config.WS_COMPLETION[len(config.WS_COMPLETION) - 1] == '/':
+ url = config.WS_COMPLETION + code
+ else:
+ url = config.WS_COMPLETION + '/' + code
+
+ f = urllib.urlopen(url)
f.read()
def run(self):
# * NOTIFY WEB SERVER ABOUT CONTENT INGESTION COMPLETION
# TODO in the future web server should also be notified about errors
try:
- self.notify_completion()
+ self.notify_completion(job['code'])
except Exception as e:
logger.log_msg(
'#%s: error while notifying web server about the job completion: %s' \
# * JOB FINISHED
Server.queue.task_done()
Server.load -= job['weight']
+ logger.log_msg('#%s: finished' \
+ % job['code'], logger.LOG_LEVEL_INFO)
class Server: