doc in new dir + bug param

pipelet.tex

-\documentclass{beamer}
-\usepackage{graphicx}
-\usepackage{amsmath}
-\usepackage[utf8]{inputenc}
-\usepackage{multicol}
-\usepackage{ulem}
-\usepackage{color}
-\usepackage{listings}
-\usepackage{wasysym}
-\useoutertheme{infolines}
-\usepackage{hangcaption}
-
-\newcommand{\unnumberedcaption}%
-%	{\@dblarg{\@unnumberedcaption\@captype}}
-
-\begin{document}
-
-\begin{frame}{Pipelet}
-\tableofcontents
-\end{frame}
-
-\section{From the user point of view}
-
-\begin{frame}{The pipelet big scheme}
-
-\end{frame}
-
-
-\subsection{Building a pipeline}
-\begin{frame}{Building a pipeline}
-Pipeline(pipedot, codedir=, prefix=)
-\begin{itemize}
-\item pipedot is the string description of the pipeline
-\item codedir is the path of the code of the segments
-\item prefix  is the path of the data repository
-\end{itemize}
-\end{frame}
-
-
-
-\subsection{Writing segment scripts}
-
-\begin{frame}{Writing segment scripts}
-\end{frame}
-
-\subsection{Executing a pipeline}
-\subsection{Browsing a pipeline}
-
-
-
-
-\section{From the developper point of view}
-
-\subsection{The pipelet actors}
-
-\begin{frame}{The pipelet actors}
-\end{frame}
-
-\subsection{The pipeline object}
-
-\subsection{The task object}
-
-
-
-
-\end{document}
\ No newline at end of file

pipelet/static/seg_default_code.py

@@ -42,11 +42,11 @@ save_products (output_fn, globals(), ["D"])
 ### The parameters utilities : 
 ###
 ### The pipelet software saves automatically all parameters listed in
-### the variable named 'var_key'.
+### the variable named 'lst_par'.
 ### Some of them can be made visible from the interface using the
-### variable 'var_tag'
-var_key = ['my_dim', 'my_option', 'my_nb_of_iter']
-var_tag = ['my_dim', 'my_nb_of_iter']
+### variable 'lst_tag'
+lst_par = ['my_dim', 'my_option', 'my_nb_of_iter']
+lst_tag = ['my_dim', 'my_nb_of_iter']
 
 ### To retrieve some parameters of an upstream segment : 
 load_param ('first', globals(), ['my_previous_option'])

pipelet/tracker.py

@@ -370,8 +370,8 @@ class SqliteTracker(Tracker,threading.Thread):
                                    (status, task_output, t.ended_on, t.begun_on, t.queued_on,  t.id))
 
         if status == 'done':
-            self._asynchronous_request('update segments set param=? where seg=?',
-                                       (t.param, t.seg))
+            self._asynchronous_request('update segments set param=? where seg_id =?',
+                                       (t.param, self.seg_id_cache[t.seg]))
 
         if status =='done' or status == 'failed':
             t.store_meta(self.pipe.get_meta_file(t.seg, prod=t.task_input))       

test/seg_first_code.py

-n = 10
-lst_par=['n']
-lst_tag=['n']
+seg_output=['Lancelot', 'Galahad', 'Robin', 'Arthur']
+number_of_knights = len(seg_output)
+lst_par=['number_of_knights']
+lst_tag=lst_par
 tf = get_data_fn('test.txt')
 f = file(tf,'w')
-f.write('This segment launch %d seg_second' % n)
+f.write('This segment launch %d seg_second' % number_of_knights)
 f.close
-
-seg_output=range(n)

test/seg_fourth_code.py

 p = glob_seg('third', 'Preambule.txt')
 t = glob_seg('second','test.txt')
 import subprocess
-m = 10
 f = file(get_data_fn('result.txt'),'w')
 print (p,t)
 res = subprocess.Popen(['cat']+p+t,stdout=f).communicate()[0]

test/seg_second_code.py

@@ -3,7 +3,7 @@ tf = get_data_fn('test.txt')
 i = 0
 product = seg_input[0]
 f = file(tf,'w')
-f.write('This segment received %d as arg'%product)
+f.write('This segment received %s as arg'%product)
 f.close
 
 

test/seg_third_code.py

-pre_line = 'This is the preambule'
-lst_par = ['pre_line']
+adj = 'the_brave'
+lst_par = ['adj']
 lst_tag = lst_par
 l = 2010
 tf = get_data_fn('Preambule.txt')
 f = file(tf,'w')
-f.write(pre_line)
+f.write(adj)
 f.close
+seg_output = [adj]