File tree 3 files changed +8
-7
lines changed
3 files changed +8
-7
lines changed Original file line number Diff line number Diff line change @@ -44,7 +44,7 @@ def queue_jobs(jobs):
44
44
45
45
# Wrap job objects in Celery task function
46
46
callable_tasks = [encode_proxy .s (x ) for x in jobs ]
47
- logger .debug (f"callable_tasks: { callable_tasks } " )
47
+ logger .debug (f"[magenta] callable_tasks:[/] { callable_tasks } " )
48
48
49
49
# Create job group to retrieve job results as batch
50
50
task_group = group (callable_tasks )
Original file line number Diff line number Diff line change @@ -289,8 +289,8 @@ def get_resolve_proxy_jobs(media_pool_items):
289
289
"resolution" : str (cp ["Resolution" ]).split ("x" ),
290
290
"frames" : int (cp ["Frames" ]),
291
291
"fps" : float (cp ["FPS" ]),
292
- "h_flip" : True if cp ["H-FLIP" ] is "On" else False ,
293
- "v_flip" : True if cp ["H-FLIP" ] is "On" else False ,
292
+ "h_flip" : True if cp ["H-FLIP" ] == "On" else False ,
293
+ "v_flip" : True if cp ["H-FLIP" ] == "On" else False ,
294
294
"proxy" : cp ["Proxy" ],
295
295
"proxy_media_path" : cp ["Proxy Media Path" ]
296
296
if not len (cp ["Proxy Media Path" ])
@@ -303,6 +303,7 @@ def get_resolve_proxy_jobs(media_pool_items):
303
303
"media_pool_item" : media_pool_item ,
304
304
}
305
305
306
+ logger .debug (f"[magenta]Clip properties: { job } \n " )
306
307
jobs .append (job )
307
308
308
309
logger .info (f"[green]Total queuable clips on timeline: { len (jobs )} [/]" )
Original file line number Diff line number Diff line change 15
15
16
16
# Worker and Celery settings pulled from local user_settings file
17
17
# All other settings are passed from queuer
18
- worker_settings = SettingsManager ()
18
+ settings = SettingsManager ()
19
19
console = Console ()
20
20
21
21
core .install_rich_tracebacks ()
22
22
logger = logging .getLogger (__name__ )
23
- logger .setLevel (worker_settings ["worker" ]["loglevel" ])
23
+ logger .setLevel (settings ["worker" ]["loglevel" ])
24
24
25
25
26
26
@app .task (
@@ -57,7 +57,7 @@ def encode_proxy(self, job):
57
57
58
58
# Create proxy dir
59
59
60
- logger .debug (f"Output Dir: { job ['expected_proxy_dir' ]} " )
60
+ logger .debug (f"Output Dir: ' { job ['expected_proxy_dir' ]} ' " )
61
61
try :
62
62
63
63
os .makedirs (
@@ -86,7 +86,7 @@ def encode_proxy(self, job):
86
86
87
87
# Get Orientation
88
88
flip = str ()
89
- logger .info (f"Horizontal Flip: { job ['h_flip' ]} \n " f"Vertical Flip { job ['h_flip' ]} " )
89
+ logger .info (f"Horizontal Flip: { job ['h_flip' ]} \n " f"Vertical Flip: { job ['h_flip' ]} " )
90
90
91
91
if job ["h_flip" ]:
92
92
flip += " hflip, "
You can’t perform that action at this time.
0 commit comments