Python-сообщество

from mpi4py import MPI
comm = MPI.COMM_WORLD
rank = comm.Get_rank()
size = comm.Get_size()
if rank == 0:
  data = {'1': [0], '2': [0]}
else:
  data = None
data = comm.bcast(data , root=0)
# проверяем наличие на узлах
print "[%02d]%s" % (rank, data)

class ClassName(object):
	"""docstring for ClassName"""
	def __init__(self, arg):
		super(ClassName, self).__init__()
		self.arg = arg

class table(Base):
    engine = create_engine(url)
    metadata = MetaData(bind=engine)
    __table__ =  Table('table', metadata, autoload = True)
    session = scoped_session(sessionmaker(bind=engine, autoflush=True, expire_on_commit=True, autocommit=False)) 

update_count = 0 
for item in data.items():
       update_count +=1
       param_row = tables.table.session.query(tables.table).filter(tables.table.uid == item[0]).first()
       param_row.param_1 = item[1][1]
       param_row.param_2 = item[1][0]
#         tables.table.session.query(tables.table).filter_by(uid = item[0]).with_lockmode("update").update({'param_1':item[1][1], 'param_2':item[1][0]}) # как вариант записи которым пробывал 
#         tables.table.session.query(tables.table).filter(tables.table.uid == item[0]).with_lockmode("update").update({'param_1':item[1][1], 'param_2':item[1][0]}) # как вариант записи
        if update_count > 99: 
            tables.table.commit()
            update_count = 0         

    update_count = 0 
    for item in data.items():
            update_count += 1
            cur.execute("""
            INSERT INTO table
                (uid, params_1, _params_2)
            VALUES 
                (%s, %s, %s) 
            ON DUPLICATE KEY UPDATE 
               params_1  = VALUES(params_1), 
               params_2   = VALUES(params_2) ;
                       """, (item[0], item[1][0], item[1][1]))
            if update_count > 99:
                con.commit()
                update_count = 0    

# init threads
thread = threading.Thread(target = SMTPParser, args = (self._config, conn, addr, ))
# start threads
thread.start()

num = len(self.factory.clients)-1
 print "this client is", num

class IphoneChat(Protocol):
    def connectionMade(self):
        self.factory.clients.append(self)
        print "clients are ", self.factory.clients
    def dataReceived(self, data):
        a = data.split(':')
        command = a[0]
        content = a[1]
        if command == "iam":
		    self.name = content
		    msg = self.name + " has joined"
		    print msg
       

from System import Int16
from ctypes import windll, Structure, c_ulong, byref
class POINT(Structure):
   _fields_ = [("x", c_ulong), ("y", c_ulong)]
   
if starting:
   vJoy0_stat = False # данный флаг используется для включения передачи данных на джойстик
   Caps_Enabled = False # данный флаг используется для временного отключения джойстика
   vJoy[0].x = 0
   mouse_x = 0  # координаты мыши
   mouse_y = 0
   screen_x = windll.user32.GetSystemMetrics(0) # размер экрана
   screen_y = windll.user32.GetSystemMetrics(1)
   pt = POINT()
   preci = 100  # уточнитель задает точность измерений до сотых, используется, для сохранения дробной части в умножителе
   multipler_y = preci * 32768 / screen_y
# умножитель определяет, насколько нужно увеличить значение положения курсора, чтобы джойстик корректно отклонялся от центра экрана
# enable/disable mouse vJoy X/Y control by pressing CapsLock
if keyboard.getPressed(Key.CapsLock):
   if vJoy0_stat:
		vJoy0_stat = False
		Caps_Enabled = False
		vJoy[0].x = 0
   		vJoy[0].y = 0
   else:
		vJoy0_stat = True
		Caps_Enabled = True
#mouse.middleButton - средняя кнопка мыши
#mouse.rightButton .leftButton - правая или левая кнопка мыши и т.п.
# деактивация джойстика, если нажата средняя кнопка мыши и включен капслок
if mouse.middleButton and Caps_Enabled:
	vJoy0_stat = False
# активация джойстика, если отпущена средняя кнопка мыши и включен капслок
if not mouse.middleButton and Caps_Enabled:
	vJoy0_stat = True
if vJoy0_stat:
   windll.user32.GetCursorPos(byref(pt))
   if pt.x > 65536: mouse_x = 0 # добавлено, так как при выходе значения за пределы int, происходил вылет скрипта
   else: mouse_x = pt.x
   if pt.y > 65536: mouse_y = 0 # добавлено, так как при выходе значения за пределы int, происходил вылет скрипта
   else: mouse_y = pt.y
# положение джойстика определяется как положение мыши на экране - половина ширина экрана умноженная на увеличитель и разделенная на уточнитель 
   vJoy[0].x = (mouse_x - (screen_x / 2)) * multipler_y / preci
   vJoy[0].y = (mouse_y - (screen_y / 2)) * multipler_y / preci
#диагностическая часть скрипта
diagnostics.watch(vJoy0_stat)
diagnostics.watch(Caps_Enabled)
diagnostics.watch(mouse.middleButton)

@receiver(pre_save, sender=Item)
def item_pre_save_callback(sender, **kwargs):
    instance = kwargs['instance']

raise ValidationError

class PyQtEventLoopOp(bpy.types.Operator):
    bl_idname = "povray.map"
    bl_label = "Rainbow"
    _timer = None
    _window = None
    def modal(self, context, event):
        if event.type == 'TIMER':
            self._event_loop.processEvents()
            self._application.sendPostedEvents(None, 0) 
        return {'PASS_THROUGH'}
    def execute(self, context):
        self._application = QApplication.instance()
        if self._application is None:
            self._application = QApplication(['blender'])
        self._event_loop = QEventLoop()
        self.window = EditorWindow()
        self._timer = context.window_manager.event_timer_add(0.1, context.window)
        context.window_manager.modal_handler_add(self)
        return {'RUNNING_MODAL'}