Ignore:
Timestamp:
3 Feb 2010, 15:37:32 (15 years ago)
Author:
uli
Message:

Update tests.

File:
1 edited

Legend:

Unmodified
Added
Removed

  • main/waeup.sirp/trunk/src/waeup/sirp/datacenter.txt

    r4962 r4999  
    143143    ...  'mysource.csv', create_pending=False)
    144144    >>> mydatacenter.distProcessedFiles(True, src, finished_src,
    145     ...                            pending_src)
     145    ...                            pending_src, mode='create')
    146146    >>> sorted(os.listdir(dc_root))
    147147    ['finished', 'logs', 'unfinished']
    148148
    149149    >>> sorted(os.listdir(fin_dir))
    150     ['mysource.csv', 'mysource.finished.csv']
     150    ['mysource.create.finished.csv', 'mysource.csv']
    151151
    152152    >>> sorted(os.listdir(unfin_dir))
    … …  
    168168    ...  'mysource.csv')
    169169    >>> mydatacenter.distProcessedFiles(False, src, finished_src,
    170     ...                                 pending_src)
    171     >>> sorted(os.listdir(dc_root))
    172     ['finished', 'logs', 'mysource.pending.csv', 'unfinished']
    173 
    174     >>> sorted(os.listdir(fin_dir))
    175     ['mysource.finished.csv']
     170    ...                                 pending_src, mode='create')
     171    >>> sorted(os.listdir(dc_root))
     172    ['finished', 'logs', 'mysource.create.pending.csv', 'unfinished']
     173
     174    >>> sorted(os.listdir(fin_dir))
     175    ['mysource.create.finished.csv']
    176176
    177177    >>> sorted(os.listdir(unfin_dir))
    … …  
    186186
    187187    >>> tmp_dir, src, finished_src, pending_src = create_fake_results(
    188     ...  'mysource.pending.csv', create_pending=False)
     188    ...  'mysource.create.pending.csv', create_pending=False)
    189189    >>> mydatacenter.distProcessedFiles(True, src, finished_src,
    190     ...                                 pending_src)
     190    ...                                 pending_src, mode='create')
    191191
    192192    >>> sorted(os.listdir(dc_root))
    … …  
    194194
    195195    >>> sorted(os.listdir(fin_dir))
    196     ['mysource.csv', 'mysource.finished.csv']
     196    ['mysource.create.finished.csv', 'mysource.csv']
    197197
    198198    >>> sorted(os.listdir(unfin_dir))
    … …  
    210210    ...  'mysource.csv')
    211211    >>> mydatacenter.distProcessedFiles(False, src, finished_src,
    212     ...                                 pending_src)
     212    ...                                 pending_src, mode='create')
    213213
    214214We try to process the pending file, which fails again:
    215215
    216216    >>> tmp_dir, src, finished_src, pending_src = create_fake_results(
    217     ...  'mysource.pending.csv')
    218     >>> mydatacenter.distProcessedFiles(False, src, finished_src,
    219     ...                                 pending_src)
     217    ...  'mysource.create.pending.csv')
     218    >>> mydatacenter.distProcessedFiles(False, src, finished_src,
     219    ...                                 pending_src, mode='create')
    220220
    221221We try to process the new pending file:
    222222
    223223    >>> tmp_dir, src, finished_src, pending_src = create_fake_results(
    224     ...  'mysource.pending.csv')
    225     >>> mydatacenter.distProcessedFiles(False, src, finished_src,
    226     ...                                 pending_src)
    227 
    228     >>> sorted(os.listdir(dc_root))
    229     ['finished', 'logs', 'mysource.pending.csv', 'unfinished']
    230 
    231     >>> sorted(os.listdir(fin_dir))
    232     ['mysource.finished.csv']
     224    ...  'mysource.create.pending.csv')
     225    >>> mydatacenter.distProcessedFiles(False, src, finished_src,
     226    ...                                 pending_src, mode='create')
     227
     228    >>> sorted(os.listdir(dc_root))
     229    ['finished', 'logs', 'mysource.create.pending.csv', 'unfinished']
     230
     231    >>> sorted(os.listdir(fin_dir))
     232    ['mysource.create.finished.csv']
    233233
    234234    >>> sorted(os.listdir(unfin_dir))
    … …  
    238238
    239239    >>> tmp_dir, src, finished_src, pending_src = create_fake_results(
    240     ...  'mysource.pending.csv', create_pending=False)
     240    ...  'mysource.create.pending.csv', create_pending=False)
    241241    >>> mydatacenter.distProcessedFiles(True, src, finished_src,
    242     ...                                 pending_src)
     242    ...                                 pending_src, mode='create')
    243243
    244244    >>> sorted(os.listdir(dc_root))
    … …  
    246246
    247247    >>> sorted(os.listdir(fin_dir))
    248     ['mysource.csv', 'mysource.finished.csv']
     248    ['mysource.create.finished.csv', 'mysource.csv']
    249249
    250250    >>> sorted(os.listdir(unfin_dir))
Note: See TracChangeset for help on using the changeset viewer.