Stacked @card v1.2 : Customizing @card with current.card

metaflow/cards.py

@@ -1,21 +1,19 @@
 from metaflow.plugins.cards.card_client import get_cards
 from metaflow.plugins.cards.card_modules.card import MetaflowCardComponent, MetaflowCard
+from metaflow.plugins.cards.card_modules.components import (
+    Artifact,
+    Table,
+    Image,
+    Error,
+    Markdown,
+)
 from metaflow.plugins.cards.card_modules.basic import (
     DefaultCard,
-    TitleComponent,
-    SubTitleComponent,
-    SectionComponent,
-    ImageComponent,
-    BarChartComponent,
-    LineChartComponent,
-    TableComponent,
-    DagComponent,
     PageComponent,
-    ArtifactsComponent,
     RENDER_TEMPLATE_PATH,
     TaskToDict,
     DefaultComponent,
-    ChartComponent,
     TaskInfoComponent,
     ErrorCard,
+    BlankCard,
 )

metaflow/graph.py

@@ -298,6 +298,8 @@ def node_to_dict(name, node):
                 d["foreach_artifact"] = node.foreach_param
             elif d["type"] == "split-parallel":
                 d["num_parallel"] = node.num_parallel
+            if node.matching_join:
+                d["matching_join"] = node.matching_join
             return d
 
         def populate_block(start_name, end_name):

metaflow/metaflow_config.py

@@ -64,26 +64,29 @@ def from_conf(name, default=None):
 DATATOOLS_SUFFIX = from_conf("METAFLOW_DATATOOLS_SUFFIX", "data")
 DATATOOLS_S3ROOT = from_conf(
     "METAFLOW_DATATOOLS_S3ROOT",
-    "%s/%s" % (from_conf("METAFLOW_DATASTORE_SYSROOT_S3"), DATATOOLS_SUFFIX)
+    os.path.join(from_conf("METAFLOW_DATASTORE_SYSROOT_S3"), DATATOOLS_SUFFIX)
     if from_conf("METAFLOW_DATASTORE_SYSROOT_S3")
     else None,
 )
 # Local datatools root location
 DATATOOLS_LOCALROOT = from_conf(
     "METAFLOW_DATATOOLS_LOCALROOT",
-    "%s/%s" % (from_conf("METAFLOW_DATASTORE_SYSROOT_LOCAL"), DATATOOLS_SUFFIX)
+    os.path.join(from_conf("METAFLOW_DATASTORE_SYSROOT_LOCAL"), DATATOOLS_SUFFIX)
     if from_conf("METAFLOW_DATASTORE_SYSROOT_LOCAL")
     else None,
 )
 
+# Cards related config variables
 DATASTORE_CARD_SUFFIX = "mf.cards"
 DATASTORE_CARD_LOCALROOT = from_conf("METAFLOW_CARD_LOCALROOT")
 DATASTORE_CARD_S3ROOT = from_conf(
     "METAFLOW_CARD_S3ROOT",
-    "%s/%s" % (from_conf("METAFLOW_DATASTORE_SYSROOT_S3"), DATASTORE_CARD_SUFFIX)
+    os.path.join(from_conf("METAFLOW_DATASTORE_SYSROOT_S3"), DATASTORE_CARD_SUFFIX)
     if from_conf("METAFLOW_DATASTORE_SYSROOT_S3")
     else None,
 )
+CARD_NO_WARNING = from_conf("METAFLOW_CARD_NO_WARNING", False)
+
 # S3 endpoint url
 S3_ENDPOINT_URL = from_conf("METAFLOW_S3_ENDPOINT_URL", None)
 S3_VERIFY_CERTIFICATE = from_conf("METAFLOW_S3_VERIFY_CERTIFICATE", None)

metaflow/plugins/__init__.py

@@ -150,17 +150,32 @@ def get_plugin_cli():
 _merge_lists(FLOW_DECORATORS, _ext_plugins["FLOW_DECORATORS"], "name")
 
 # Cards
-from .cards.card_modules.basic import DefaultCard, TaskSpecCard, ErrorCard
-from .cards.card_modules.test_cards import TestErrorCard, TestTimeoutCard, TestMockCard
+from .cards.card_modules.basic import DefaultCard, TaskSpecCard, ErrorCard, BlankCard
+from .cards.card_modules.test_cards import (
+    TestErrorCard,
+    TestTimeoutCard,
+    TestMockCard,
+    TestPathSpecCard,
+    TestEditableCard,
+    TestEditableCard2,
+    TestNonEditableCard,
+)
+from .cards.card_modules import MF_EXTERNAL_CARDS
 
 CARDS = [
     DefaultCard,
     TaskSpecCard,
     ErrorCard,
+    BlankCard,
     TestErrorCard,
     TestTimeoutCard,
     TestMockCard,
-]
+    TestPathSpecCard,
+    TestEditableCard,
+    TestEditableCard2,
+    TestNonEditableCard,
+    BlankCard,
+] + MF_EXTERNAL_CARDS
 # Sidecars
 from ..mflog.save_logs_periodically import SaveLogsPeriodicallySidecar
 from metaflow.metadata.heartbeat import MetadataHeartBeat