Skip to content

Commit

Permalink
FIX: typo
Browse files Browse the repository at this point in the history
  • Loading branch information
kevinkle committed Apr 10, 2018
1 parent c5b30bd commit 406df62
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 4 deletions.
10 changes: 7 additions & 3 deletions app/middleware/models.py
Original file line number Diff line number Diff line change
Expand Up @@ -215,14 +215,18 @@ def __init__(self, jobs=None, files=None, func=None, options=None, date=None):
now = datetime.now()
now = now.strftime("%Y-%m-%d-%H-%M-%S-%f")
date = now
self.jobs = {} # {'somename': instance of RQ.Job} Only used when enqueing.
self.final_jobs = {} # Jobs for every file in the request.
self.cache = [] # For temporary storage of RQ.Jobs.

# Variables for generating run signature.
self.sig = None
self.files = files
self.func = func # Additional attribute for storing pipeline function.
self.options = options
self.signature() # Create & Store a signature for the pipeline.

# Addition variables.
self.jobs = {} # {'somename': instance of RQ.Job} Only used when enqueing.
self.final_jobs = {} # Jobs for every file in the request.
self.cache = [] # For temporary storage of RQ.Jobs.
self.date = date
self.done = False # Bypass for the self.complete() method.

Expand Down
2 changes: 1 addition & 1 deletion app/routes/ra_posts.py
Original file line number Diff line number Diff line change
Expand Up @@ -283,7 +283,7 @@ def upload():
pipeline = pipeline
)
jobs_dict.update(jobs_enqueued)
pipeline.cache_jobs(filename)
pipeline.cache_jobs(f)

print 'upload(): all files enqueued, returning...'
pipeline.merge_jobs()
Expand Down

0 comments on commit 406df62

Please sign in to comment.