<reponame>sinonkt/pachelm<filename>tests/integration_test.py
import pytest
from pachelm.migration import PachydermMigration

def test_find_pipeline_config(ctx):
    # print(ctx)
    # print(ctx.migrations)
    # migration = PachydermMigration(ctx)
    # difference = migration.diff('test-pipeline', ctx.find_pipeline_config('test-pipeline').get('path'))
    # diff(ctx)
    assert 5 == 5
    # print(verify_is_pipeline_exists(ctx, 'test-pipeline'))
    # jobs = list(ctx.pps.list_job('test-pipeline').job_info)
    # list(map(lambda x: x, jobs))
    # pipelines = list(ctx.pps.list_pipeline().pipeline_info)
    # print(jobs)
    # print(pipelines)
    
    # print(jobs[0].state)
    # for job in jobs:
    #     print(job)
    # print(list(map(jobs.job_info, lambda x: x.state)))
    # print((jobs, lambda x: x.state)))
    # for job in enumerate(jobs):
    #     print(job)

    # filePath = '%s/eiei.json' % (ctx.pachydermConfigsDir)
    # migration.create_pipeline_from_file(filePath)

import pytest
from pachelm.migration import PachydermMigration

def test_find_pipeline_config(ctx):
    # print(ctx)
    # print(ctx.migrations)
    # migration = PachydermMigration(ctx)
    # difference = migration.diff('test-pipeline', ctx.find_pipeline_config('test-pipeline').get('path'))
    # diff(ctx)
    assert 5 == 5
    # print(verify_is_pipeline_exists(ctx, 'test-pipeline'))
    # jobs = list(ctx.pps.list_job('test-pipeline').job_info)
    # list(map(lambda x: x, jobs))
    # pipelines = list(ctx.pps.list_pipeline().pipeline_info)
    # print(jobs)
    # print(pipelines)
    
    # print(jobs[0].state)
    # for job in jobs:
    #     print(job)
    # print(list(map(jobs.job_info, lambda x: x.state)))
    # print((jobs, lambda x: x.state)))
    # for job in enumerate(jobs):
    #     print(job)

    # filePath = '%s/eiei.json' % (ctx.pachydermConfigsDir)
    # migration.create_pipeline_from_file(filePath)
# print(ctx) # print(ctx.migrations) # migration = PachydermMigration(ctx) # difference = migration.diff('test-pipeline', ctx.find_pipeline_config('test-pipeline').get('path')) # diff(ctx) # print(verify_is_pipeline_exists(ctx, 'test-pipeline')) # jobs = list(ctx.pps.list_job('test-pipeline').job_info) # list(map(lambda x: x, jobs)) # pipelines = list(ctx.pps.list_pipeline().pipeline_info) # print(jobs) # print(pipelines) # print(jobs[0].state) # for job in jobs: #     print(job) # print(list(map(jobs.job_info, lambda x: x.state))) # print((jobs, lambda x: x.state))) # for job in enumerate(jobs): #     print(job) # filePath = '%s/eiei.json' % (ctx.pachydermConfigsDir) # migration.create_pipeline_from_file(filePath)