o
    QDid                     @   sL   d dl Z d dlZd dlZd dlmZmZ dd Zdd Zdd Zd	d
 Z	dS )    N)Pipelinestepsc                  C   s.   t t gd} |  dddigiksJ d S )N)r   r   typetable-normalize)r   r   table_normalizeto_descriptorpipeline r
   d/var/www/Datamplify/venv/lib/python3.10/site-packages/frictionless/pipeline/__spec__/test_convert.pytest_pipeline_to_descriptor   s   r   c                  C   sh   t t% ddddigigi} t| }| dddigiks"J W d    d S 1 s-w   Y  d S )Ntasksr   r   r   )pytestwarnsUserWarningr   from_descriptorr   )
descriptorr	   r
   r
   r   0test_pipeline_from_descriptor_tasks_framework_v4   s
   
"r   c                  C   s\   t d} d}t|}t|  t| ksJ W d    d S 1 s'w   Y  d S )Nzdata/pipeline.jsondata/pipeline.yaml)r   r   openyaml	safe_loadto_yamlread)r	   expected_file_pathfiler
   r
   r   test_pipeline_to_yaml   s
   

""r   c                  C   s4   t d} t|  dddddgdksJ d S )Nr   r	   zcell-set
populationd   )r   	fieldNamevalue)namer   )r   r   jsonloadsto_jsonr   r
   r
   r   test_pipeline_to_json&   s
   
r%   )
r"   r   r   frictionlessr   r   r   r   r   r%   r
   r
   r
   r   <module>   s    
