# pylint: disable=missing-docstring
from resolwe.flow.models import Data

from .utils import skipDockerFailure, BioProcessTestCase


class AbyssProcessorTestCase(BioProcessTestCase):

    @skipDockerFailure("Errors with: KeyError: u'unmapped' at "
        "self.run_processor('assembler-abyss', inputs)")
    def test_abyss(self):
        se_reads = self.prepare_reads('reads.fastq.gz')

        inputs = {'src1': 'reads_paired_abyss_1.fastq.gz', 'src2': 'reads_paired_abyss_2.fastq.gz'}
        reads = self.run_processor('upload-fastq-paired', inputs)

        inputs = {'paired_end': reads.pk,
                  'se': se_reads.pk,
                  'options': {'k': 25,
                              'name': 'ecoli'}}

        self.run_processor('assembler-abyss', inputs)

        inputs = {'paired_end': reads.pk,
                  'se': se_reads.pk,
                  'use_unmapped': True,
                  'options': {'k': 25,
                              'name': 'ecoli'}}

        self.run_processor('assembler-abyss', inputs, Data.STATUS_ERROR)

53db55f06da49f0602e19baec3560fe959999649
<mask token>

<mask token>


class AbyssProcessorTestCase(BioProcessTestCase):
    <mask token>

<mask token>


class AbyssProcessorTestCase(BioProcessTestCase):

    @skipDockerFailure(
        "Errors with: KeyError: u'unmapped' at self.run_processor('assembler-abyss', inputs)"
        )
    def test_abyss(self):
        se_reads = self.prepare_reads('reads.fastq.gz')
        inputs = {'src1': 'reads_paired_abyss_1.fastq.gz', 'src2':
            'reads_paired_abyss_2.fastq.gz'}
        reads = self.run_processor('upload-fastq-paired', inputs)
        inputs = {'paired_end': reads.pk, 'se': se_reads.pk, 'options': {
            'k': 25, 'name': 'ecoli'}}
        self.run_processor('assembler-abyss', inputs)
        inputs = {'paired_end': reads.pk, 'se': se_reads.pk, 'use_unmapped':
            True, 'options': {'k': 25, 'name': 'ecoli'}}
        self.run_processor('assembler-abyss', inputs, Data.STATUS_ERROR)

from resolwe.flow.models import Data
from .utils import skipDockerFailure, BioProcessTestCase


class AbyssProcessorTestCase(BioProcessTestCase):

    @skipDockerFailure(
        "Errors with: KeyError: u'unmapped' at self.run_processor('assembler-abyss', inputs)"
        )
    def test_abyss(self):
        se_reads = self.prepare_reads('reads.fastq.gz')
        inputs = {'src1': 'reads_paired_abyss_1.fastq.gz', 'src2':
            'reads_paired_abyss_2.fastq.gz'}
        reads = self.run_processor('upload-fastq-paired', inputs)
        inputs = {'paired_end': reads.pk, 'se': se_reads.pk, 'options': {
            'k': 25, 'name': 'ecoli'}}
        self.run_processor('assembler-abyss', inputs)
        inputs = {'paired_end': reads.pk, 'se': se_reads.pk, 'use_unmapped':
            True, 'options': {'k': 25, 'name': 'ecoli'}}
        self.run_processor('assembler-abyss', inputs, Data.STATUS_ERROR)

# pylint: disable=missing-docstring
from resolwe.flow.models import Data

from .utils import skipDockerFailure, BioProcessTestCase


class AbyssProcessorTestCase(BioProcessTestCase):

    @skipDockerFailure("Errors with: KeyError: u'unmapped' at "
        "self.run_processor('assembler-abyss', inputs)")
    def test_abyss(self):
        se_reads = self.prepare_reads('reads.fastq.gz')

        inputs = {'src1': 'reads_paired_abyss_1.fastq.gz', 'src2': 'reads_paired_abyss_2.fastq.gz'}
        reads = self.run_processor('upload-fastq-paired', inputs)

        inputs = {'paired_end': reads.pk,
                  'se': se_reads.pk,
                  'options': {'k': 25,
                              'name': 'ecoli'}}

        self.run_processor('assembler-abyss', inputs)

        inputs = {'paired_end': reads.pk,
                  'se': se_reads.pk,
                  'use_unmapped': True,
                  'options': {'k': 25,
                              'name': 'ecoli'}}

        self.run_processor('assembler-abyss', inputs, Data.STATUS_ERROR)
