Dominoes fucked around with this message at 00:46 on May 20, 2013

QuarkJets fucked around with this message at 03:33 on May 20, 2013

Dominoes fucked around with this message at 03:43 on May 20, 2013

Dominoes fucked around with this message at 11:46 on May 20, 2013

Dominoes fucked around with this message at 03:07 on May 22, 2013

Sab669 fucked around with this message at 16:10 on May 22, 2013

Dominoes fucked around with this message at 22:51 on May 22, 2013

Dominoes fucked around with this message at 22:38 on May 22, 2013

import os
from coroutine import coroutine

@coroutine
def do_thing_to_file(arg1, arg2):
    while True:
        try:
            filepath = (yield)
            # do stuff here
        except GeneratorExit:
            return

@coroutine
def dirwalk(target):
    """Walk a directory structure and send file paths to target
    
    Use .send() to provide a directory name to walk.

    arguments:
    target - coroutine to send file paths to
    """
    while True:
        try:
            dirpath = (yield)
            for root, dirs, files in os.walk(dirpath):
                for filename in files:
                    filepath = os.path.sep.join([root, filename])
                    target.send(filepath)
        except GeneratorExit:
            target.close()
            return

@coroutine
def track_processed(processed, target):
    """Forward what it is sent to target then record that processing completed

    Use .send() to provide data to forward.

    arguments:
    target    - coroutine to forward to
    processed - list where processed items are stored
    """
    while True:
        try:
            item = (yield)
            target.send(item)
            processed.append(item)
        except GeneratorExit:
            target.close()
            return

def main():
    processed = []
    try:
        pipeline = dirwalk(
                       track_processed(processed,
                           do_thing_to_file(arg1="arg1value", arg2="arg2value")
                       )
                   )
        pipeline.send('/')
    except IOError as e:
        print str(e)
        print 'Processed files before error: %s' % ', '.join(processed)

if __name__ == '__main__':
    main()

def counter(start):
    value = start
    while True:
        new_value = (yield value)
        if new_value is not None:
            value = new_value
        else:
            value += 1

c = counter(1)

print c.next()
print c.next()
print c.next()
print c.send(16)
print c.next()
print c.next()

$ python coroutine_justification.py 
1
2
3
16
17
18

Dren fucked around with this message at 22:37 on May 22, 2013

file = tempfile.NamedTemporaryFile().name + filename
    with open(file, 'wb') as f:

path = dir + '\\temporary\\'
empty_temp()
for plate in plates:
    filename = ...
    url = ...
    web_file = get(url).content
    save_path = path + filename
    with open(save_path, 'wb') as f:
            f.write(web_file)
    combine()
    with open(path + 'Plates.pdf', 'rb') as f: 
        return f.read()

def combine():
    path = dir + '\\temporary\\'
    filenames = [f for f in listdir(path) if f.endswith('.pdf')]     
    if len(filenames) > 0:
        merger = PdfFileMerger()
        for f in filenames:
            merger.append(fileobj = path + f)
        with open(path + 'Plates.pdf', 'wb') as f: 
            merger.write(f)
        merger.close()

Dominoes fucked around with this message at 00:47 on May 23, 2013

def download_combined(window, plates):
    global d2
    d = tempfile.TemporaryDirectory()
    d2 = d.name
    for plate in plates:
        filename = ...
        url = ...
        web_file = get(url).content
        with open(d2 + '\\' + filename, 'wb')  as f:
            f.write(web_file)
    combine()
    window.ui.statusbar.showMessage("Download complete") 
    with open(d2 + '\\Plates.pdf', 'rb') as f:
        return f.read()

        
def combine():
    filenames = [f for f in listdir(d2) if f.endswith('.pdf')]     
    if len(filenames) > 0:
        merger = PdfFileMerger()
        for f in filenames:
            merger.append(fileobj = d2 + '\\' + f)
        with open(d2 + '\\Plates.pdf', 'wb') as f: 
            merger.write(f)
        merger.close()

Dominoes fucked around with this message at 02:55 on May 23, 2013