diff --git a/livestreams.py b/livestreams.py
index 0615afd32a2e2300eda6f0e8db920aa3dadf0946..d0d66d372c370fdde2189ec400761baa3ba60191 100644
--- a/livestreams.py
+++ b/livestreams.py
@@ -154,7 +154,7 @@ def streamauth(server):
 		modify('UPDATE live_sources SET server = NULL, clientid = NULL, preview_key = NULL, last_active = ? WHERE server = ? AND clientid = ?', datetime.now(), server, request.values['clientid'])
 		if not source:
 			return 'Ok', 200
-		for lecture in query('SELECT lectures FROM lectures WHERE stream_job IS NOT NULL'):
+		for lecture in query('SELECT * FROM lectures WHERE stream_job IS NOT NULL'):
 			settings = json.loads(lecture['stream_settings'])
 			if source['id'] in [settings.get('source1'), settings.get('source2')]:
 				cancel_job(lecture['stream_job'])