Version 6.x.x Source

Class FileAndRedisStream

Inherits from __builtin__.file

__init__ (self)

No docs


write (self, data)

No docs



Public API
/api/method/frappe.async.can_subscribe_doc

frappe.async.can_subscribe_doc (doctype, docname, sid)

No docs


frappe.async.emit_via_redis (event, message, room)

Publish real-time updates via redis

Parameters:


frappe.async.get_doc_room (doctype, docname)

No docs


Public API
/api/method/frappe.async.get_pending_tasks_for_doc

frappe.async.get_pending_tasks_for_doc (doctype, docname)

No docs


frappe.async.get_redis_server ()

Returns memcache connection.


frappe.async.get_site_room ()

No docs


frappe.async.get_std_streams (task_id)

No docs


frappe.async.get_task_log_file_path (task_id, stream_type)

No docs


frappe.async.get_task_progress_room ()

No docs


Public API
/api/method/frappe.async.get_task_status

frappe.async.get_task_status (task_id)

No docs


Public API
/api/method/frappe.async.get_user_info

frappe.async.get_user_info (sid)

No docs


frappe.async.get_user_room (user)

No docs


frappe.async.handler (f)

No docs


frappe.async.is_file_old (file_path)

No docs


Public API
/api/method/frappe.async.ping

frappe.async.ping ()

No docs


frappe.async.publish_realtime (event=None, message=None, room=None, user=None, doctype=None, docname=None, now=False)

Publish real-time updates

Parameters:


frappe.async.put_log (line_no, line, task_id=None)

No docs


frappe.async.remove_old_task_logs ()

No docs


frappe.async.set_task_status (task_id, status, response=None)

No docs