summaryrefslogtreecommitdiff
path: root/plac/doc/importer3.py
blob: 2a47e99f4066a6644f63da9c2656a3ec61dfb739 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
import time
import plac

class FakeImporter(object):
    "A fake importer with an import_file command"
    mpcommands = ['import_file']
    def __init__(self, dsn):
        self.dsn = dsn
    def import_file(self, fname):
        "Import a file into the database"
        try:
            for n in range(10000):
                time.sleep(.02)
                if n % 100 == 99:
                    yield 'Imported %d lines' % (n+1)
        finally:
            print('closing the file')

if __name__ == '__main__':
    plac.Interpreter.call(FakeImporter)