@@ -297,17 +297,16 @@ def __init__(self, *args, **kwargs):
297297kwargs ['resource_name' ]= 'jobs'
298298super (Job ,self ).__init__ (* args ,** kwargs )
299299
300- def create (self ,input ,outputs = None ,options = None ):
300+ def create (self ,input = None , live_stream = False ,outputs = None ,options = None ):
301301"""
302- Creates a job
302+ Creates atranscoding job.
303303
304304 @param input: the input url as string
305+ @param live_stream: starts an RTMP Live Stream
305306 @param outputs: a list of output dictionaries
306307 @param options: a dictionary of job options
307308 """
308- as_test = int (self .test )
309-
310- data = {"input" :input ,"test" :as_test }
309+ data = {"input" :input ,"test" :self .test }
311310if outputs :
312311data ['outputs' ]= outputs
313312
@@ -364,6 +363,10 @@ def delete(self, job_id):
364363 """
365364return self .cancel (job_id )
366365
366+ def finish (self ,job_id ):
367+ """ Finishes the live stream for `job_id`. """
368+ return self .put (self .base_url + '/%s/finish' % str (job_id ))
369+
367370class Report (HTTPBackend ):
368371def __init__ (self ,* args ,** kwargs ):
369372"""
@@ -404,3 +407,4 @@ def minutes(self, start_date=None, end_date=None, grouping=None):
404407
405408url = self .base_url + '/minutes'
406409return self .get (url ,data = data )
410+
