Skip to content

Commit

Permalink
Docs updates
Browse files Browse the repository at this point in the history
  • Loading branch information
vikilab committed May 1, 2019
1 parent ea1a95a commit 85cd118
Show file tree
Hide file tree
Showing 5 changed files with 23 additions and 10 deletions.
6 changes: 4 additions & 2 deletions README.rst
Original file line number Diff line number Diff line change
Expand Up @@ -6,17 +6,19 @@ ragnar
.. image:: https://img.shields.io/pypi/v/ragnar.svg
:target: https://pypi.python.org/pypi/ragnar

.. image:: https://img.shields.io/travis/juanmcrisobal/ragnar.svg
.. image:: https://img.shields.io/travis/vikilab/ragnar.svg
:target: https://travis-ci.org/vikilab/ragnar

.. image:: https://readthedocs.org/projects/ragnar/badge/?version=latest
:target: https://ragnar.readthedocs.io/en/latest/?badge=latest
:alt: Documentation Status

.. image:: https://coveralls.io/repos/github/vikilab/ragnar/badge.svg?branch=master
:target: https://coveralls.io/github/vikilab/ragnar?branch=master



grok management library
Ragnar is a lightweight Extract-Transform-Load (ETL) framework for Python 3.5+.


* Free software: MIT license
Expand Down
12 changes: 12 additions & 0 deletions ragnar/stream.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,9 @@ def __build__(self):
self.iter = iter(self.value)

def __rebuild__(self):
"""
This method will regenerate the iterator.
"""
if self.repeatable:
self.iter, self.iter_repeatable = tee(self.iter_repeatable)

Expand All @@ -60,6 +63,9 @@ def __next__(self):
raise StopIteration

def __show_next__(self):
"""
This method allows you to treat the item before showing it.
"""
item = self.iter.__next__()

if isinstance(item, types.GeneratorType):
Expand All @@ -68,9 +74,15 @@ def __show_next__(self):
return item

def do(self, func, chain=False):
"""
This method adds a function to apply to the execution stack.
"""
self.__stack__.append(type('FunctionFactory', (object,), {'type': 'do', 'fuction': func, 'chain': chain}))
return self

def filter(self, func):
"""
This method adds a filter to apply to the execution stack.
"""
self.__stack__.append(type('FunctionFactory', (object,), {'type': 'filter', 'fuction': func}))
return self
1 change: 0 additions & 1 deletion requirements.txt
Original file line number Diff line number Diff line change
@@ -1 +0,0 @@
Click==7.0
2 changes: 2 additions & 0 deletions requirements_dev.txt
Original file line number Diff line number Diff line change
Expand Up @@ -10,3 +10,5 @@ coveralls==1.7.0
pytest-cov==2.6.1
sphinx-rtd-theme==0.4.3
wheel==0.33.1
watchdog==0.9.0
bumpversion==0.5.3
12 changes: 5 additions & 7 deletions setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,22 +13,20 @@

requirements = []

setup_requirements = ['pytest-runner', ]
setup_requirements = []

test_requirements = ['pytest', ]
test_requirements = []

setup(
author="vikilab",
author_email='vikilab.library@gmail.com',
classifiers=[
'Development Status :: 2 - Pre-Alpha',
'Development Status :: 4 - Beta',
'Intended Audience :: Developers',
'License :: OSI Approved :: MIT License',
'Natural Language :: English',
"Programming Language :: Python :: 2",
'Programming Language :: Python :: 2.7',
'Programming Language :: Python :: 3',
'Programming Language :: Python :: 3.4',
'Topic :: Documentation :: Sphinx',
'Topic :: Text Processing',
'Programming Language :: Python :: 3.5',
'Programming Language :: Python :: 3.6',
'Programming Language :: Python :: 3.7',
Expand Down

0 comments on commit 85cd118

Please sign in to comment.